kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=consumer-1
错误日志：
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;至少大于等于应用部署节点数
kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=consumer-1相关推荐
- druid抛出的异常------javax.management.InstanceAlreadyExistsException引发的一系列探索
druid抛出的异常------javax.management.InstanceAlreadyExistsException引发的一系列探索 参考文章: (1)druid抛出的异常------jav ...
- Caused by: javax.management.InstanceAlreadyExistsException: MXBean already registered with name org.
在Configuration的配置类上加上以下注解 @EnableMBeanExport(registration = RegistrationPolicy.IGNORE_EXISTING)
- 【Kafka笔记】4.Kafka API详细解析 Java版本（Producer API，Consumer API，拦截器等）
简介 Kafka的API有Producer API,Consumer API还有自定义Interceptor (自定义拦截器),以及处理的流使用的Streams API和构建连接器的Kafka Con ...
- 学习笔记Kafka（六）—— Kafka Consumer API及开发实例
一.Kafka Consumer API 1.1.Consumer 1.2.KafkaConsumer 1.3.ConsumerRecords 1.4.ConsumerRecord 1.5.Kafka ...
- javax.management.InstanceNotFoundException: com.alibaba.druid:type=DruidStatService ERROR com.aliba
2019独角兽企业重金招聘Python工程师标准>>> javax.management.InstanceNotFoundException: com.alibaba.druid:t ...
- javax.management.InstanceNotFoundException: org.springframework.boot:type=Admin,name=SpringApplicati
控制台service端打印javax.management.InstanceNotFoundException: org.springframework.boot:type=Admin,name=Sp ...
- 【Flink实战系列】Lorg/apache/flink/kafka/shaded/org/apache/kafka/clients/consumer/ConsumerRecord；)Ljava/
java.lang.AbstractMethodError: Method flink/stream/deserialization/PoJoDeserializationSchema.deseria ...
- 【莹伙丛】javax.management.InstanceNotFoundException: org.springframework.boot:type=Admin,name=SpringAppl
[莹伙丛]javax.management.InstanceNotFoundException: org.springframework.boot:type=Admin,name=SpringAppl ...
- 解决ERROR - unregister mbean error javax.management.InstanceNotFoundException: com.alibaba.druid:type=
项目中使用druid对数据库连接池进行管理,在本地及测试环境均无问题,但是上了生产环境后,每当tomcat第一次启动时,日志未报错,但是页面总是出不来,在关闭tomcat时,看日志,发现报错如下: E ...
最新文章
- extlinux安装livecd到USB
- Bash Cookbook 学习笔记 【高级】
- 【开源】WeChatRobot+WeChatHelper 制作自己的微信机器人
- AI基础：一文看懂BERT
- ie11上vue中使用elementui的input框无法输入中文
- dataframe常用操作_Pandas | Dataframe的merge操作，像数据库一样尽情join
- [ Javascript ] JavaScript中的定时器(Timer) 是怎样工作的!
- 小甲鱼 OllyDbg 教程系列 (九) ：Delphi 程序逆向特点
- 典型海洋环境观测数据产品应用现状及对我国的启示
- C++——《算法分析》实验肆——单源最短路径问题
- rz安装 xshell_在Linux系统中安装rzsz工具
- 一个简单实用的boost升压电路
- 机器人仿真的应用价值
- phpmailer 私密抄送_PHPMailer发匿名邮件及Extension missing: openssl的解决
- 瀚高数据库和mysql区别,瀚高数据库----select用法
- VS 2010 与 VS 2008的区别
- 基于石墨烯的光电探测传感器研究
- Java操作Word转PDF（Word转图片）
- 清华源阿里源 centos
- 二层与三层交换机配置