高并发场景下Kafka消费者组Rebalance风暴：如何实现检测→告警→自愈闭环？

背景：Kafka消费者组Rebalance风暴常导致数据丢失、延迟激增，传统方案需业务代码改造。

常见分歧：

1. 『监控+熔断』派：通过JVM指标预警+消费者降级
2. 『元数据治理』派：优化topic分区策略+副本分配
3. 『链路注入』派：在生产者端埋点控制消费速率

我的倾向：建议采用『轻量级元数据+智能熔断』组合方案，通过Consumer Group的authoritative broker做流量预判，结合Prometheus+AlertManager实现秒级响应。

想听听大家：在实际生产中，你们如何平衡『系统稳定性』与『开发成本』？哪些场景更适合用『无侵入式治理』？