java - SpringKafka 禁用消费者再平衡

Question

这可能是一个愚蠢的问题，但我很好奇是否可以在 Spring Kafka 中禁用消费者重新平衡。想象一下，我有一个包含 3 个分区和 3 个不同消费者的主题，它们使用 @KafkaListener 在不同的 TopicPartitions 上运行。如果其中一位消费者宕机，是否有可能不让再平衡发生？（我想做手动偏移管理，当消费者起来时，我想从我离开的地方开始）。

标签： javakafka-consumer-apispring-kafka

Answer 1

您可以在自动偏移为 false 的每个分区上拥有三个不同的消费者，您可以手动提交偏移量。因此，每当消费者停止并启动时，它将从先前的偏移量中读取，并且还将消费者分配给特定分区不会在其他分区之间重新平衡