我在apachenifi中使用consumekafka来使用来自一个具有15个分区的kafka主题的数据。consumekafka处理器有18个并发(6个节点*3个并发任务/节点)在以下群集上运行的线程总数:10我期望总线程数=15,因为我的kafka主题有15个分区。我也看到了15个独特的消费者ID。在这种情况下,nifi如何分配线程?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!