KafkaConsumer是非线程安全的，那么怎么样实现多线程消费？
发布于 2020-05-19 18:13:18
关注者
0
被浏览
2185
1 个回答
-
1.在每个线程中新建一个KafkaConsumer 2.单线程创建KafkaConsumer，多个处理线程处理消息（难点在于是否要考虑消息顺序性，offset的提交方式）
