KafkaConsumer是非线程安全的,那么怎么样实现多线程消费?

KafkaConsumer是非线程安全的,那么怎么样实现多线程消费?,第1张

KafkaConsumer是非线程安全的,那么怎么样实现多线程消费?

1.在每个线程中新建一个KafkaConsumer

2.单线程创建KafkaConsumer,多个处理线程处理消息难点在于是否要考虑消息顺序性,offset的提交方式)

欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/zaji/4879886.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2022-11-11
下一篇2022-11-11

发表评论

登录后才能评论

评论列表(0条)

    保存