[KAFKA-1083] Unregister JMX MBean when shutting down ConsumerConnector

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Duplicate
• Affects Version/s: 0.8.0
• Component/s: consumer
• Assignee: Neha Narkhede
• Reporter: Tanguy
• Created: 11/Oct/13 13:08
• Updated: 14/Jun/15 08:47
• Resolved: 14/Jun/15 08:47

Description

In our application, we are currently starting a Kafka Consumer with the
following lines of code:

connector = Consumer.createJavaConsumerConnector(consumerConfig);
streams = connector .createMessageStreams(map);

Then, each KafkaStream is processed in a dedicated thread per topic and
partition, as documented here
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example

When we call:

connector.shutdown()

We can see that the MBean is not unregistered at shutdown time and still "alive" even if the consumer connector has been shut down.

Issue Links

• is duplicated by: KAFKA-1567 Metric memory leaking after closing the clients