我是 kafka 新手,我的问题是如何创建具有多个消费者实例的多个消费者组,并分配该消费者实例从特定代理或分区进行消费?例如:我必须按照此示例图像 所示实现
最佳答案
消费者组与高级消费者 API 相关,而选择要消费的代理或分区的能力与简单消费者 API 相关。
高级 API 将自动为您在组中的使用者之间进行重新平衡,但它将消耗给定主题的所有分区。
如果您只想从主题内的特定分区进行消费,则需要使用简单的消费者 API,并且必须自己处理分区分配。 Kafka wiki 中有一个如何执行此操作的示例。 .
关于apache-kafka - kafka中的多个消费组,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28693858/