加入收藏 | 设为首页 | 会员中心 | 我要投稿 我爱制作网_池州站长网 (https://www.0566zz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 站长学院 > PHP教程 > 正文

1.11_Release Kafka阅读器错误

发布时间:2022-11-11 10:46:36 所属栏目:PHP教程 来源:
导读:  代码代码新后,仍然仍然,错误打印有变化。

  配置如下:

  “读者”:{

  “姓名”:“kafkader”,

  “参数“:{

  ”主题&ldq
  代码代码新后,仍然仍然,错误打印有变化。
 
  配置如下:
 
  “读者”:{
 
  “姓名”:“kafkader”,
 
  “参数“:{
 
  ”主题“:”test“,
 
  ”编解码器“:”文本“,
 
  ”模式“:”特定偏移“,
 
  ”偏移“:”分区:0, offset:0“,
 
  ”消费者“:{
 
  ”bootstrap.servers“:”10.64.3.31:9092“
 
  }
 
  }
 
  }php阅读器,
 
  错误打印如下:
 
  2021-03-31 15:32:31.676 [遗留源线程 - 来源:Kafkareader - >下沉: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 )
 

(编辑:我爱制作网_池州站长网)

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