max.poll.interval.ms参数用于指定consumer两次poll的最大时间间隔（默认5分钟），如果超过了该间隔consumer client会主动向coordinator发起Leave ...

前面说过了consumer心跳机制：consumer定期向coordinator发送心跳请求，以表明自己还在线；如果session.timeout.ms内未发送请求，coordinator认为其不可用 ...

auto.offset.reset用来指定consumer消费策略，有如下取值： 1、latest（分区有提交的offset，从提交的offset后一个offset开始消费；否则等待新生产的数据）【 ...

分区结构 如下图是官网上kafka三级结构图，三级结构为主题---分区---消息，并且每条消息只能保存在某一个分区内； kafka虽然是一个队列但是不保证消息有序，但是对于分区来说消息是有序的 ...

kafka中有三种语义： 1、at-most-once 配置应答模式ack为0时，只要消息到了broker无论是否写成功，就回复ok，这样可能导致消息没有写入kafka；这种做法一般是为了减少消息 ...

KafkaConsumer是非线程安全的，多线程共享一个KafkaConsumer实例，kafka会有如下异常：java.util.ConcurrentModificationException: K ...