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)