我有一个Kafka监听器,它处于停止状态。我用一个api调用启动它,然后根据一些内部条件停止它。当我多次点击api时,我希望它的多个线程独立运行。有办法吗?我用SpringKafka和Spring Boot。
cbjzeqam1#
设置 concurrency 属性获取多个线程。必须至少有和并发一样多的分区(一个组中只有一个使用者可以同时使用一个分区)。
concurrency
1条答案
按热度按时间cbjzeqam1#
设置
concurrency
属性获取多个线程。必须至少有和并发一样多的分区(一个组中只有一个使用者可以同时使用一个分区)。