Spring Kafka 禁用消费者再平衡

【问题标题】：SpringKafka Disable Consumer RebalancingSpring Kafka 禁用消费者再平衡
【发布时间】：2018-08-10 15:12:54
【问题描述】：

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

【问题讨论】：

标签： java kafka-consumer-api spring-kafka

【解决方案1】：

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

【讨论】：

要完全禁用再平衡，您可以显式地将分区分配给实例，而不是使用组管理（代理将分区分配给活动消费者）。见the documentation 和here。
是的，我的意思只是，为每个分区分配不同的消费者并禁用自动偏移，从而完全控制主题分区