我是kafka的新手，我的问题是如何创建具有多个消费者示例的多个消费者组，并将该消费者示例分配给特定的代理或分区？例如：我必须实现如这个例子所示的图像
5rgfhyps1#
消费者组与高级消费者api相关，而选择从中消费的代理或分区的能力与简单消费者api相关。高级api将自动为您在组中的使用者之间进行重新平衡，但它将使用给定主题的所有分区。如果您只想从主题中的特定分区进行消费，则需要使用简单的使用者api，并且必须自己处理分区分配。Kafka维基上有一个这样做的例子。
1条答案
按热度按时间5rgfhyps1#
消费者组与高级消费者api相关，而选择从中消费的代理或分区的能力与简单消费者api相关。
高级api将自动为您在组中的使用者之间进行重新平衡，但它将使用给定主题的所有分区。
如果您只想从主题中的特定分区进行消费，则需要使用简单的使用者api，并且必须自己处理分区分配。Kafka维基上有一个这样做的例子。