1.在每个线程中新建一个KafkaConsumer
2.单线程创建KafkaConsumer,多个处理线程处理消息(难点在于是否要考虑消息顺序性,offset的提交方式)
上一篇 谈一谈,java中有哪些代理模式?
下一篇 你们公司的自动化投入产出比怎样?效益怎样?
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号:晋ICP备2021003244-6号