[ https://issues.apache.org/jira/browse/KAFKA-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xavier Léauté updated KAFKA-4856: --------------------------------- Description: 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. {noformat} 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) {noformat} was: 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. {noformat} 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) {noformat} > 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.9.0.0, 0.10.0.0, 0.10.2.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. > {noformat} > 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) > {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)