如何手动触发Kafka重平衡？单Broker Docker本地部署测试Golang服务场景

以下方法在本地Docker单节点Kafka环境下均可正常使用：

1. 启停消费者组内的消费者实例 #

该方法最贴合线上实际业务的重平衡场景，优先推荐使用

• 触发逻辑：同一个消费者组下新增/减少消费者实例时，Kafka会自动触发重平衡
• 具体操作：
  1. 可以多启动一个你的Golang服务实例，加入同一个消费者组
  2. 也可以停掉当前正在运行的1个消费者实例，等待session.timeout.ms超时后即可触发重平衡
• 加速触发技巧：测试环境可以调低消费者配置的session.timeout.ms到3000ms，停掉实例后最多3秒就会触发重平衡

2. 修改订阅主题的分区数量 #

• 触发逻辑：主题分区数发生变更时，所有订阅该主题的消费者组都会自动触发重平衡
• 具体操作：
  进入Kafka Docker容器，执行分区扩容命令，例如给test_topic扩容到8个分区：
  kafka-topics.sh --alter --topic test_topic --partitions 8 --bootstrap-server localhost:9092

注意：Kafka分区仅支持扩容不支持缩容，测试完成后如果要恢复原有分区数，需要删除重建主题

3. 变更消费者组的订阅关系 #

• 触发逻辑：消费者组内的实例新增/取消订阅某个主题时，会触发重平衡
• 具体操作：可以在你的Golang服务中添加临时逻辑，比如接收指定信号后额外订阅一个空的测试主题，或者取消订阅当前的某一个主题，触发重平衡后再恢复原有订阅即可

4. 删除消费者组偏移量触发重平衡 #

• 触发逻辑：消费者组的偏移量信息被清空后，下次有消费者实例接入时会触发重平衡
• 具体操作：
  先停止该消费者组的所有消费者实例，进入Kafka Docker容器执行命令：
  kafka-consumer-groups.sh --delete --group 你的消费者组名称 --bootstrap-server localhost:9092
  重启你的Golang消费者服务后就会触发重平衡

• 单Broker环境无法模拟Broker宕机导致的重平衡场景，但以上4种方法已经可以覆盖绝大多数业务侧遇到的重平衡场景，足够完成你的Golang服务测试
• 你可以通过以下命令查看消费者组状态，确认重平衡是否触发：
  kafka-consumer-groups.sh --describe --group 你的消费者组名称 --bootstrap-server localhost:9092
  重平衡过程中消费者组状态会显示为Rebalancing，完成后变为Stable

内容的提问来源于stack exchange，提问作者Yura