触发消费者组的再平衡

Trigger rebalance of a consumer group

有没有办法在不重启 spring kafka 容器的情况下手动触发重新平衡(并且在元数据最大年龄之前)?从 Kafka 2.6 开始,有 enforceRebalance() 来触发消费者 API 的再平衡,但它在 spring kafka 容器中是私有的。

您可以将 Consumer 作为参数添加到侦听器并对其调用 enforceRabalance(),重新平衡将在下一次轮询时发生。

如果容器空闲,你可以设置一个idleEventInterval并且消费者在ListenerContainerIdleEvent中可用。

https://docs.spring.io/spring-kafka/docs/current/reference/html/#idle-containers

https://docs.spring.io/spring-kafka/docs/current/reference/html/#event-consumption