记录下和kafka相关的Message、日志文件、索引文件、consumer记录消费的offset相关内容，文中很多理解参考文末博文、书籍还有前辈。 kafka中的消息 kafka中的消息Message，在V1版本中是如下部分组成，主要关系key和value。 （1）key：当需要将消息写入到某个t ...
分类：
其他好文 时间：
2020-03-22 01:01:11
阅读次数：
82
前言 本文介绍服务定位器模式（Service Locator Pattern），并提供了 UML 图和示例 Java 代码。 服务定位器模式 服务定位器模式实现了按需返回服务实例 。在该模式中，应用所有需要的服务都会被注册到服务定位器中，并通过 ID 唯一标识。应用需要哪个服务，用这个 ID 就能从 ...
分类：
其他好文 时间：
2020-03-21 12:54:55
阅读次数：
62
一.基于erlang语言： 是一种支持高并发的语言 RabbitMQ的六种工作模式： 1.1 simple简单模式 消息产生着§将消息放入队列 消息的消费者(consumer) 监听(while) 消息队列,如果队列中有消息,就消费掉,消息被拿走后,自动从队列中删除(隐患 消息可能没有被消费者正确处 ...
分类：
其他好文 时间：
2020-03-20 17:15:51
阅读次数：
76
Feign是受到Retrofit，JAXRS-2.0和WebSocket启发的java客户端联编程序。Feign的第一个目标是将约束分母的复杂性统一到http apis，而不考虑其稳定性。在employee-consumer的例子中，我们使用了employee-producer使用REST模板公开的 ...
分类：
Web程序 时间：
2020-03-19 09:13:57
阅读次数：
229
1、main方法中（1.0以上） import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.c ...
分类：
其他好文 时间：
2020-03-18 21:36:32
阅读次数：
83
26. 删除排序数组中的重复项 给定一个排序数组，你需要在 原地 删除重复出现的元素，使得每个元素只出现一次，返回移除后数组的新长度。 不要使用额外的数组空间，你必须在 原地 修改输入数组 并在使用 O(1) 额外空间的条件下完成。 示例 1: 给定数组 nums = [1,1,2], 函数应该返回 ...
分类：
编程语言 时间：
2020-03-17 08:25:53
阅读次数：
49
使用RestTemplate对象访问请求出错 Cannot construct instance of (no Creators, like default construct, exist): cannot deserialize from Object value (no delegate or ...
分类：
其他好文 时间：
2020-03-15 10:09:59
阅读次数：
100
[toc] 选择自动提交还是手动提交方式和业务场景相关，可以查看前面的博客，根据原理进行选择。 单线程消费 pom consumerConfig consumer 批量消费 开启批量消费需要3步 1、消费者设置 max.poll.records/ 2、消费者 开启批量消费 factory.setBa ...
分类：
编程语言 时间：
2020-03-13 20:52:10
阅读次数：
82
消费者位移的提交方式以及提交时机需要根据不同的业务场景进行选择，可以看之前的博客kafka消费者相关。 这里只做应用相关，更多的使用场景，该怎么用、何时用要看前面的博客了解原理。 参考博客：https://blog.csdn.net/yy756127197/article/details/10389 ...
分类：
编程语言 时间：
2020-03-13 20:44:37
阅读次数：
98
一、创建模块（microservice-consumer-movie-feign-customizing）项目结构如下：在这里插入图片描述二、pom.xml文件<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.o
分类：
微信 时间：
2020-03-12 09:31:26
阅读次数：
90
