kafka中的多个消费者组

Multiple consumer groups in kafka

我是 kafka 的新手,我的问题是如何创建具有多个消费者实例的多个消费者组并分配该消费者实例以从特定代理或分区消费?例如:我必须按照本示例图像

所示实施

消费者组与高级消费者API相关,而选择代理或分区进行消费的能力与简单消费者API有关。

高级 API 会自动为您在组中的消费者之间进行重新平衡,但它会消耗给定主题的所有分区。

如果您只想从主题中的特定分区消费,则需要使用简单的消费者 API,并且您必须自己处理分区分配。 Kafka wiki.

中有一个如何执行此操作的示例