1.在每个线程中新建一个KafkaConsumer2.单线程创建KafkaConsumer,多个处理线程处理消息(难点在于是否要考虑消息顺序性,offset的提交方式)
上一篇 请介绍一下bean的生命周期
下一篇 String 为什 么是不可变的?
版权所有 (c)2021-2022 MSHXW.COM
ICP备案号:晋ICP备2021003244-6号