Chaos2018

kafka在springboot环境下多线程请求和多线程消费

kafka在springboot环境下多线程请求和多线程消费 1.需求描述: 接到一个需求,A模块将某些渠道获取的数据发送到kafka,B模块从kafka消费数据,设置的主题是r2p5,即设置了5个分区,为了消费速度最大化,代码中设置了五个线程 开发完生产者的代码如下: //pom.xml引入kaf

posted on 2022-03-02 11:15  Chaos2018  阅读(4910)  评论(0编辑  收藏  举报

导航