如何触发Kafka重新平衡?

Yur*_*ura 2 apache-kafka

我需要针对 kafka 重新平衡测试我的 golang 服务。我怎样才能手动触发它?

我在 Docker 本地运行 kafka。我有一个经纪人。有什么办法强制卡夫卡这样做吗?

cri*_*007 7

卡夫卡不会重新平衡;消费者群体这样做。

您需要运行消费者的多个实例,然后停止一些实例并观察正在运行的实例的行为