apache-kafka - kafka中的多个消费组

标签 apache-kafka

我是 kafka 新手,我的问题是如何创建具有多个消费者实例的多个消费者组,并分配该消费者实例从特定代理或分区进行消费?例如:我必须按照此示例图像 enter image description here 所示实现

最佳答案

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

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

如果您只想从主题内的特定分区进行消费,则需要使用简单的消费者 API,并且必须自己处理分区分配。 Kafka wiki 中有一个如何执行此操作的示例。 .

关于apache-kafka - kafka中的多个消费组,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28693858/

相关文章:

apache-kafka - 具有更改日志主题与日志压缩源主题的 Kafka Streams KTable 存储

java - 从多个 Kafka 主题同时读取 1 条消息

apache-kafka - I/O 中的 Kafka 错误 java.io.EOFException : null

apache-kafka - Kafka Producer 无法发送消息

java - 如何将 RESTful 服务器与 Apache Kafka 结合起来?

apache-spark - Kafka Producer-找不到org.apache.kafka.common.serialization.StringSerializer

docker - dockerizing Java Spring Boot 应用程序的优势?

java - 如何使用 jhipster 在 Kafka 集群上设置多个代理

Python如何删除Kafka主题下的所有消息