kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app

错误日志：

2019-10-11 17:50:48.744 WARN []-[o.a.k.clients.consumer.ConsumerConfig :173] The configuration num.replica.fetchers = 1 was supplied but isn't a known config.
2019-10-11 17:50:48.747 INFO []-[o.a.kafka.common.utils.AppInfoParser :82] Kafka version : 0.9.0.1
2019-10-11 17:50:48.747 INFO []-[o.a.kafka.common.utils.AppInfoParser :83] Kafka commitId : 23c69d62a0cabf06
2019-10-11 17:50:48.747 WARN []-[o.a.kafka.common.utils.AppInfoParser :59] Error registering AppInfo mbean
javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=consumer-1
at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:437)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1898)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:966)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:900)
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:324)
at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522)
at org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:57)
at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:640)

原因：kafa 分区数小于应用部署节点数

处理方式：kafka 为topic增加partition;至少大于等于应用部署节点数

命令： bin/kafka-topics.sh --alter --zookeeper 10.112.179.12:2181 --partitions 10 --topic gome

相关知识

kafka
关于kafka的Connection to node
Kafka数据安全性、运行原理、存储
设置type=“range”为vertical
若a=5,b=“a＜10”，则？TYPE(B) 输出结果为
Python语句序列“a=121+1.21；print（type（a））”的输出
使input type=“file” 不可编辑
代码学习库—— 一 Type的使用
input[type=“file”] change事件第二次不触发
自定义(滑动条)input[type=“range”]样式

原文链接: kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app https://www.huajiangbk.com/newsview1012175.html