1.在每个线程中新建一个KafkaConsumer2.单线程创建KafkaConsumer，多个处理线程处理消息（难点在于是否要考虑消息顺序性，offset的提交方式）
欢迎分享，转载请注明来源：内存溢出
赞
(0)
打赏
微信扫一扫
支付宝扫一扫
微信扫一扫
支付宝扫一扫
什么最佳优先算法（Best
上一篇
2022-11-11
请介绍一下bean的生命周期
下一篇
2022-11-11
评论列表（0条）