目录 bootstrap.servers group.id fetch.min.bytes fetch.max.bytes fetch.max.wait.ms ...

一、生产者配置 属性 描述 类型 默认值 重要性 bootstrap.servers 用于建立与kafka集群的连接，这个list仅仅影响用于初始化的hosts，来发现全部的servers。格式 ...

Kafka消费者Demo 依赖包： 源码： ...

最近的业务接触了一下消息插件kafka ，其他客户端负责发送，我方负责接收消费。功能很简单，但是！！！！我们要求把消息入库，而且数据量每天达到了千万级别，这就日了苟啊！ 废话不多说，上代码！ 由于消息需要入库，我使用的是手动提交消息，如果不入库，不要求准确定，使用自动提交就ok ...

一、消费者和消费者群组 　　在 Kafka 中，消费者通常是消费者群组的一部分，多个消费者群组共同读取同一个主题时，彼此之间互不影响。Kafka 之所以要引入消费者群组这个概念是因为 Kafka 消费者经常会做一些高延迟的操作，比如把数据写到数据库或 HDFS ，或者进行耗时的计算，在这些情况下 ...

消费者组 kafka 使用消费者组来控制消费组消费，每个消费组都可以消费 topic 的全量信息，消费组内部的消费者再各自进行引流，消费不同的分区信息。 消费者从属于消费组，一个组里的消费者订阅的是相同的主题，每个消费者接收主题一部分的分区的消息。 一个消费者组只有一个消费者的情况 ...

fetch.min.bytes 该属性指定了消费者’从服务器获取记录的最小字节数。 broker 在收到消费者的数据请求时， 如果可用的数据量小于fetch.min.bytes 指定的大小，那么它会等到有足够的可用数据时才把它返回给消费者。 作用:可以降低消费者和 broker 的工作负载 ...

消费者api，自动提交offset 手动提交offset，同步提交 手动提交offset，异步提交 ...