Xavier Léauté created KAFKA-4856:
------------------------------------

             Summary: Calling KafkaProducer.close() from multiple threads may 
cause spurious error
                 Key: KAFKA-4856
                 URL: https://issues.apache.org/jira/browse/KAFKA-4856
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 0.10.2.0, 0.10.0.0, 0.9.0.0
            Reporter: Xavier Léauté
            Priority: Minor


Calling KafkaProducer.close() from multiple threads simultaneously may cause 
the following harmless error message to be logged. There appears to be a 
race-condition in AppInfoParser.unregisterAppInfo that we don't guard against. 

{{WARN Error unregistering AppInfo mbean 
(org.apache.kafka.common.utils.AppInfoParser:71)
javax.management.InstanceNotFoundException: 
kafka.producer:type=app-info,id=<client id>
    at 
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.getMBean(DefaultMBeanServerInterceptor.java:1095)
    at 
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.exclusiveUnregisterMBean(DefaultMBeanServerInterceptor.java:427)
    at 
com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.unregisterMBean(DefaultMBeanServerInterceptor.java:415)
    at 
com.sun.jmx.mbeanserver.JmxMBeanServer.unregisterMBean(JmxMBeanServer.java:546)
    at 
org.apache.kafka.common.utils.AppInfoParser.unregisterAppInfo(AppInfoParser.java:69)
    at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:735)
    at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:686)
    at 
org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:665)}}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to