我有一个Flink Kafka消费者，可以从多个kafka主题中读取（在我的情况下为3个） . kafka上每个主题有5个分区 . Flink默认创建了多少消费者 .
是吗：
每个主题
5个消费者 . 即 . 在所有15个消费者中
共有5个消费者 .
kafka消息的消耗非常慢，因此我无法确定每个主题附加的消费者数量 .
消费者的数量等于源功能的并行性 . 源操作符的每个并行实例只有一个使用者 . 如果你没有取消配置并行性，我认为它可能默认为一个并行性，这肯定会解释缓慢 .
如果您正在运行独立群集，webGUI将在运行时向您显示源功能的并行性 .
1 回答
消费者的数量等于源功能的并行性 . 源操作符的每个并行实例只有一个使用者 . 如果你没有取消配置并行性，我认为它可能默认为一个并行性，这肯定会解释缓慢 .
如果您正在运行独立群集，webGUI将在运行时向您显示源功能的并行性 .