[KAFKA-4856] Calling KafkaProducer.close() from multiple threads may cause spurious error - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Minor
Resolution: Fixed
Affects Version/s: 0.9.0.0, 0.10.0.0, 0.10.2.0
Fix Version/s: 0.11.0.1, 1.0.0
Component/s: clients
Labels:
None

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.

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)