Mailing-List: contact jira-help@kafka.apache.org; run by ezmlm
Precedence: bulk
Reply-To: jira@kafka.apache.org
Date: Fri, 21 Jul 2017 14:44:01 +0000 (UTC)
From: "Ismael Juma (JIRA)" <jira@apache.org>
To: jira@kafka.apache.org
Message-ID: <JIRA.12992594.1469543668000.302480.1500648241801@Atlassian.JIRA>
In-Reply-To: <JIRA.12992594.1469543668000@Atlassian.JIRA>
References: <JIRA.12992594.1469543668000@Atlassian.JIRA> <JIRA.12992594.1469543668924@jira-lw-us.apache.org>
Subject: [jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException
 Error for Consumers Starting in Parallel
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Fri, 21 Jul 2017 14:44:08 -0000


    [ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16096330#comment-16096330 ] 

Ismael Juma commented on KAFKA-3992:
------------------------------------

https://github.com/apache/kafka/pull/3328 is related, but it seems to go in the other direction. cc [~guozhang] [~mjsax]

> InstanceAlreadyExistsException Error for Consumers Starting in Parallel
> -----------------------------------------------------------------------
>
>                 Key: KAFKA-3992
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3992
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.9.0.0, 0.10.0.0
>            Reporter: Alexander Cook
>            Assignee: Ewen Cheslack-Postava
>             Fix For: 0.11.1.0
>
>
> I see the following error sometimes when I start multiple consumers at about the same time in the same process (separate threads). Everything seems to work fine afterwards, so should this not actually be an ERROR level message, or could there be something going wrong that I don't see? 
> Let me know if I can provide any more info! 
> Error processing messages: Error registering mbean kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
> org.apache.kafka.common.KafkaException: Error registering mbean kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
>  
> Caused by: javax.management.InstanceAlreadyExistsException: kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
> Here is the full stack trace: 
> M[?:com.ibm.streamsx.messaging.kafka.KafkaConsumerV9.produceTuples:-1]  - Error processing messages: Error registering mbean kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
> org.apache.kafka.common.KafkaException: Error registering mbean kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
> 	at org.apache.kafka.common.metrics.JmxReporter.reregister(JmxReporter.java:159)
> 	at org.apache.kafka.common.metrics.JmxReporter.metricChange(JmxReporter.java:77)
> 	at org.apache.kafka.common.metrics.Metrics.registerMetric(Metrics.java:288)
> 	at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:177)
> 	at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:162)
> 	at org.apache.kafka.common.network.Selector$SelectorMetrics.maybeRegisterConnectionMetrics(Selector.java:641)
> 	at org.apache.kafka.common.network.Selector.poll(Selector.java:268)
> 	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:270)
> 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:303)
> 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:197)
> 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:187)
> 	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:126)
> 	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorKnown(AbstractCoordinator.java:186)
> 	at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:857)
> 	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:829)
> 	at com.ibm.streamsx.messaging.kafka.KafkaConsumerV9.produceTuples(KafkaConsumerV9.java:129)
> 	at com.ibm.streamsx.messaging.kafka.KafkaConsumerV9$1.run(KafkaConsumerV9.java:70)
> 	at java.lang.Thread.run(Thread.java:785)
> 	at com.ibm.streams.operator.internal.runtime.OperatorThreadFactory$2.run(OperatorThreadFactory.java:137)
> Caused by: javax.management.InstanceAlreadyExistsException: kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--1
> 	at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:449)
> 	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1910)
> 	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:978)
> 	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:912)
> 	at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:336)
> 	at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:534)
> 	at org.apache.kafka.common.metrics.JmxReporter.reregister(JmxReporter.java:157)
> 	... 18 more


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)