java kafka消费者类如何处理分区?

问题描述 投票:0回答:1

我基本上有一个包含 Spring Boot 应用程序多个任务的系统,使用以相同消费者组 ID 运行的 Kafka 消费者类。它们都与同一主题相关。我没有分配任何分区逻辑。所以我想了解如何处理这个问题。 Kafka 代理会自动将分区分配给各个任务,还是每个实例都会消耗所有分区?

java spring-boot apache-kafka spring-kafka kafka-consumer-api
1个回答
0
投票

假设您使用组管理,而不是自己分配分区,代理将执行分配。同一组中只有一个消费者可以从分区中进行消费。当另一个消费者启动或停止时,代理将在新的消费者组之间重新平衡分区。

© www.soinside.com 2019 - 2024. All rights reserved.