1.11_Release Kafka阅读器错误

代码代码新后，仍然仍然，错误打印有变化。

配置如下：

“读者”：{

“姓名”：“kafkader”，

“参数“：{

”主题“：”test“，

”编解码器“：”文本“，

”模式“：”特定偏移“，

”偏移“：”分区：0， offset：0“，

”消费者“：{

”bootstrap.servers“：”10.64.3.31:9092“

}

}

}php阅读器，

错误打印如下：

2021-03-31 15：32：31.676 [遗留源线程 - 来源：Kafkareader - ＆gt;下沉：mysqlwriter（1/1）] warn org.apache.kafka.common.utils.appinfoparser - 错误注册appinfo mbean

在com.sun.jmx.mbeanserver.repository.addmbean（reposory.java:437）

在com.sun.jmx.interceptor.defaultmbeanserverinterceptor.registerwithrepository（defaultmbeanserverinterceptor.java:1898） sun.jmx.interceptor.defaultmbeanserverinterceptor.registerdynamicmbean（defaultmbeanserverinterceptor.java:966）

在com.sun.jmx.interceptor.defaultmbeanserverinterceptor.registermbject（defaultmbeanserverinterceptor.java:900）

在com.sun.jmx.interceptor。 defaultmbeanserverinterceptor.registermbean（defaultmbeanserverinterceptor.java:324）

在com.sun.jmx.mbeanserver.jmxmbeanserver.registermbean（jmxmbeanserver.java:522）

在org.apache.kafka.common.utils.appinfoparser.registerappinfo（ appinfoparser.java:62）

在org.apache.kafka.clients.consumer.kafkaconsumer。（kafkaconsumer.j ava：773）

在org.apache.kafka.clients.consumer.kafkaconsumer。（kafkaconsumer.java:635）

在org.apache.kafka.clients.consumer.kafkaconsumer。（kafkaconsumer.java:617）

在com.dtstack.flinkx.kafka.client.kafkaclient。（kafkaclient.java:75）

在com.dtstack.flinkx.kafka.client.kafkaconsumer.createClient（Kafkaconsumer.java:45）

在com.dtstack.flinkx.kafkabase.format.kafkabaseInputFormat.openinternal（KafkabaseInputFormat.java:98）

在com.dtstack .flinkx.streaming.api.functions.source.dtinputformatsourcefuntion.run（dtinputformatsourcefunction.java:124）

在org.apache.flink.streaming.api.operators.streamsource.run（streeSource.java:100）

在org.apache.flink.streaming.api.operators.StreamSource.Run（StreamSource.java:63）

在org.apache.flink.streaming.runtime.tasks.sourcestreamtask $ legacysourcefunctionthread.run（sourcestreamtask.java:213 ）

（编辑：晋中站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!