FlinkFlink使用默认的connector无法指定ConsumerRebalanceListener
Posted 九师兄
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink使用默认的connector无法指定ConsumerRebalanceListener相关的知识,希望对你有一定的参考价值。
文章目录
1.概述
因为我们的环境,有时候会遇到消费组死掉,或者分区reblance,然后目前我们没有做监控。就想着能不能监控一下。
我们想在消费者发生变动的时候自动检测一下kafka是否正常。
ConsumerRebalanceListener的使用参考:【Kafka】kafka 再均衡监听器 ConsumerRebalanceListener。
但是在 Flink使用默认的connector无法指定ConsumerRebalanceListener。
可以看到在源码中,方法 subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
只有kafka自己调用。
以上是关于FlinkFlink使用默认的connector无法指定ConsumerRebalanceListener的主要内容,如果未能解决你的问题,请参考以下文章
FlinkFlink 流批 一体 下 新的 Connector
FlinkFlink kafka producer 分区策略 (flink写入数据不均匀 与 数据写入 分区无数据 )
FLinkFlink 1.9 升级到 1.12.4 无配置页面 无日志
FlinkFlink Kafka 消费卡死 消费组卡死 topic无写入 实际有数据 topic正常
FlinkFlink 写入 kafka 报错 The server disconnected before a response was received
FlinkFlink SQL Cannot instantiate user function cannot assign instance LinkedMap FlinkKafkaConsum