kafka javax.management.InstanceAlreadyExistsException: kafka.consumer:type=app-info,id=consumer-1

墨蓝 2022-09-08 06:15 123阅读 0赞

错误日志：

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;至少大于等于应用部署节点数

发表评论取消回复

表情：

评论列表（有 0 条评论，123人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka由浅入深（1） Kafka的前世今生

一、Kafka是什么 Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。该项目的目标是为处理实时数据提供一个统一、高吞吐、低延迟的

桃扇骨/ 2024年04月03日 10:25/ 0 赞/ 84 阅读

相关 Kafka基础入门（1）

> 本文为读书笔记 > 文章内容来自：深入理解Kafka > Kafka开源之初使用Scala语言编写的客户端 > 从Kafka 0.9.x版本开始推出的使用 Ja

深藏阁楼爱情的钟/ 2023年03月13日 05:19/ 0 赞/ 115 阅读

相关 Kafka leader -1

问题错误日志： 21/03/28 10:17:06 WARN clients.NetworkClient: \[Consumer clientId=consumer-1, g

水深无声/ 2022年11月14日 10:10/ 0 赞/ 158 阅读

相关 1.1 Kafka 的基本概念

> 开始kafka之路 > 在0.10版本之前， Kafka仅仅作为一个消息系统，主要用来解决应用解耦、异步消息、流量削峰等问题。不过在0.10版本之后， Kafk

女爷i/ 2022年11月10日 05:39/ 0 赞/ 196 阅读

相关 kafka系列之kafka入门概论(1)

kafka入门概论 ![image-20210307103219597][] 什么是消息中间件举个例子，生产者消费者，生产者生产鸡蛋，消费者消费鸡蛋，生产者生产

墨蓝/ 2022年11月06日 01:56/ 0 赞/ 208 阅读

相关 Kafka笔记-1-kafka入门介绍

一：Kafka简介 kafka是最初由Linkedin公司开发，使用Scala语言编写，Kafka是一个分布式、分区的、多副本的、多订阅者的日志系统(分布式MQ系统)，可

傷城~/ 2022年09月22日 13:54/ 0 赞/ 207 阅读

相关 Kafka(1)

Kafka是一个分布式的消息系统。系统结构 ![0310020.png][] Broker Kafka集群包含一

电玩女神/ 2022年07月31日 15:23/ 0 赞/ 95 阅读

相关 Kafka学习（1）——kafka文档阅读笔记

以下内容，仅为文档[Kafka Documentation][]的阅读笔记。阅读时的版本为0.9.0.x。 1. 开始 1.1 引

系统管理员/ 2022年07月15日 04:21/ 0 赞/ 181 阅读

相关 Kafka学习（1）——kafka文档阅读笔记

以下内容，仅为文档[Kafka Documentation][]的阅读笔记。阅读时的版本为0.9.0.x。 1. 开始 1.1 引

比眉伴天荒/ 2022年07月15日 04:21/ 0 赞/ 207 阅读

相关 kafka的安装部署(kafka_2.10.0.1.1版本)

kafka是一种高吞吐量的分布式消息系统。支持高水平扩展。安装环境: kafka：2.10.0.1.1 资源下载 kafka：[http://kafka.apac

快来打我*/ 2022年04月04日 12:21/ 0 赞/ 331 阅读