You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 曲洋 <qu...@126.com> on 2020/04/07 06:15:22 UTC

关于Flink的Kafka client-id报错

你好，
我们使用Flink跑线上任务已经稳定运行两个多月了，一直没有什么问题，在没有任何改动的情况下突然TasManager开始挂掉，经过看日期发现，报了以下错误：
ERROR org.apache.kafka.common.metrics.Metrics                       - Error when removing metric from org.apache.kafka.common.metrics.JmxReporter
org.apache.kafka.common.KafkaException: Error registering mbean kafka.consumer:type=consumer-node-metrics,client-id=consumer-2,node-id=node--2
at org.apache.kafka.common.metrics.JmxReporter.reregister(JmxReporter.java:169)
at org.apache.kafka.common.metrics.JmxReporter.metricRemoval(JmxReporter.java:100)
at org.apache.kafka.common.metrics.Metrics.removeMetric(Metrics.java:534)
at org.apache.kafka.common.metrics.Metrics.removeSensor(Metrics.java:448)
at org.apache.kafka.common.network.Selector$SelectorMetrics.close(Selector.java:1204)
at org.apache.kafka.common.network.Selector.close(Selector.java:368)
at org.apache.kafka.clients.NetworkClient.close(NetworkClient.java:627)
at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.close(Consume
目前这个问题仍旧存在，大概每个一两个小时会出来，然后伴随TaskManager挂掉，查了资料有的说框架本身的bug，想咨询下各位有没有遇到同样的问题