Flink-多种主题的卡夫卡消费者

Question

我有一个Flink卡夫卡消费者，从多个卡夫卡主题(3在我的例子)。在kafka上，每个主题有5个分区。默认情况下，Flink创建了多少消费者。

是：

1. 每个主题有5个消费者。即。在所有15个消费者中
2. 5名消费者。

卡夫卡信息的消费非常缓慢，所以我无法计算出每个主题所附带的消费者数量。

Answer 1

使用者的数量等于源函数的并行性。源操作符的每个并行实例只有一个使用者。如果您没有配置并行性，我认为它可能默认为一个并行性，这肯定会解释速度慢的原因。

如果您正在运行一个独立的集群，webGUI将在它运行时向您展示源函数的并行性。