-
消费者
-
enable.auto.commit默认值为true，与参数
auto.commit.interval.ms一起作用，auto.commit.interval.ms默认值为5000ms，也就是说默认设置中每5秒钟，kafka consumer就把offset提交给kafka一次，如果将enable.auto.commit设置为false，则auto.commit.interval.ms就失效了。生产环境建议将enable.auto.commit设置成false，并且手动commit offset
-
auto.offset.resetearlist当各分区中有已提交的offset时，从提交的offset开始消费，无提交的offset时，从头开始消费；lastest当各分区有已提交的offset时，从已提交的offset开始消费，无提交的offset时，消费该分区新产生的数据none当分区有已提交的offset是，从已提交的offset开始消费，只要有一个分区不存在已提交的offset，则抛出异常
-
-
生产者
-
acks参数指定了必须要有多少个分区副本接收到消息，生产者才会认为消息写入是发送消息成功的，这个参数对消息丢失的可能性会产生重要影响，主参数有如下选项： -
acks=0： 把消息发送到kafka就认为发送成功。 -
acks=1： 把消息发送到kafka leader分区，并且写入磁盘就认为发送成功。 -
acks=all： 把消息发送到 Kafka Leader 分区，并且 Leader 分区的副本 Follower 对消息进行了同步就认为发送成功。
-
Kafka参数配置
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
