时间戳

首页 > 解决方案 > 集群中的活动线程数少于 Apache Nifi 中的 kafka 主题分区

apache-kafka - 集群中的活动线程数少于 Apache Nifi 中的 kafka 主题分区

问题描述

我在 Apache Nifi 中使用 ConsumeKafka 来使用来自具有 15 个分区的 kafka 主题的数据。ConsumeKafka处理器并发18（6个节点*3个并发任务/节点）

消费Kafka处理器

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

活动线程总数 = 10

我期待总线程数=15，因为我的 kafka 主题有 15 个分区。我也看到了 15 个唯一的消费者 ID。在这种情况下，nifi 如何分配线程？

每个分区的 Kafka 消费者 ID

标签： apache-kafkaapache-nifi

解决方案

推荐阅读