java - Spring Kafka 禁用消费者再平衡

Question

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

Answer 1

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