关于ConsumerRecordThreadSample模式
来源：7-7 Consumer多线程并发处理
weixin_慕仰1047700
2020-05-03
在ConsumerThreadSample经典模式中，consumer会提交offset，这样消息会被记录到是否消费成功，下次是否需要重新消费；
在ConsumerRecordThreadSample模式中，consumer不提交offset，那这意味着partition里的消息每次都会被consumer重复消费吗，因为之前也没有提交offset？consumer不提交offset一般会有什么情况呢？
写回答
2回答
-
Allen
2020-05-03
把代码贴出来呗
132020-05-06 -
小麻雀呀
2020-05-03
你可以仔细看下ConsumerRecordThreadSample代码，设置的是kafka自动提交，ConsumerThreadSample经典模式中设置的是手动提交，因为在ConsumerRecordThreadSample模式中，一个Consumer不作处理，是给多个Handler进行处理，也无法得知究竟是否成功还是失败
012020-05-04
相似问题