文章目录
1.概述
因为我们的环境，有时候会遇到消费组死掉，或者分区reblance，然后目前我们没有做监控。就想着能不能监控一下。
我们想在消费者发生变动的时候自动检测一下kafka是否正常。
ConsumerRebalanceListener的使用参考：【Kafka】kafka 再均衡监听器 ConsumerRebalanceListener。
但是在 Flink使用默认的connector无法指定ConsumerRebalanceListener。
可以看到在源码中，方法 subscribe(Collection<String> topics, ConsumerRebalanceListener listener) 只有kafka自己调用。
