[jira] [Created] (KAFKA-1083) Unregister JMX MBean when shutting down ConsumerConnector

["Tanguy (JIRA)" <ji...@apache.org>]

Tanguy created KAFKA-1083:
-----------------------------

             Summary: Unregister JMX MBean when shutting down ConsumerConnector
                 Key: KAFKA-1083
                 URL: https://issues.apache.org/jira/browse/KAFKA-1083
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 0.8
            Reporter: Tanguy
            Assignee: Neha Narkhede
            Priority: Minor


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.




--
This message was sent by Atlassian JIRA
(v6.1#6144)