卡夫卡中的同一主题的消费者数量是否有限制？

Question

对于同一 组中的同一主题，Kafka对同时连接（使用 Consumer.createJavaConsumerConnector创建）是否有限制？

我的情况是我需要消耗不同的过程（不 线程）的话题，所以我需要创建大量的高层次消费者的。

Answer 1

主要限制是拥有此主题的分区数 - 您可以创建比分区更多的消费者，但不会消耗任何东西。

Answer 2

同一消费群组内的活动消费者数量受该主题分区数量的限制。额外的消费者将充当备份，并且只有当其中一个活跃消费者关闭并且该组被重新平衡时才会开始消费。

如果您需要在多个进程中使用同一份数据，则您的消费者应该位于不同的消费群体中。您可以拥有的消费者群体数量没有限制。