我基本上有一个包含 Spring Boot 应用程序多个任务的系统,使用以相同消费者组 ID 运行的 Kafka 消费者类。它们都与同一主题相关。我没有分配任何分区逻辑。所以我想了解如何处理这个问题。 Kafka 代理会自动将分区分配给各个任务,还是每个实例都会消耗所有分区?
假设您使用组管理,而不是自己分配分区,代理将执行分配。同一组中只有一个消费者可以从分区中进行消费。当另一个消费者启动或停止时,代理将在新的消费者组之间重新平衡分区。