集群中的活动线程数小于apachenifi中的kafka主题分区

5jdjgkvh  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(257)

我在apachenifi中使用consumekafka来使用来自一个具有15个分区的kafka主题的数据。consumekafka处理器有18个并发(6个节点*3个并发任务/节点)

在以下群集上运行的线程总数:10

我期望总线程数=15,因为我的kafka主题有15个分区。我也看到了15个独特的消费者ID。在这种情况下,nifi如何分配线程?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题