有没有一种方法可以启动kafka监听器的多个线程,而kafka监听器只能通过api定义一次?

yduiuuwa  于 2021-07-09  发布在  Java
关注(0)|答案(1)|浏览(285)

我有一个Kafka监听器,它处于停止状态。我用一个api调用启动它,然后根据一些内部条件停止它。当我多次点击api时,我希望它的多个线程独立运行。有办法吗?我用SpringKafka和Spring Boot。

cbjzeqam

cbjzeqam1#

设置 concurrency 属性获取多个线程。必须至少有和并发一样多的分区(一个组中只有一个使用者可以同时使用一个分区)。

相关问题