Is that in 0.7 or 0.8? JMX won't allow a bean with the same name to be registered twice. Do you see 2 beans with similar names? What are the exact bean names?
Thanks, Jun On Thu, Oct 10, 2013 at 2:42 AM, Tanguy tlrx <tlrx....@gmail.com> wrote: > Hi all, > > 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 > > We need to stop (halt) and restart the consumer. Today, we just call: > > connector.shutdown() > > and wait for threads to terminate. > > To restart the consumer, we create a new connector: > > connector = Consumer.createJavaConsumerConnector(consumerConfig); > > When restarting is complete, I can see that a JMX MBean (we use Metrics > JMXReporter) like "ZookeeperConsumerConnector" is registered twice. This > bean is not registered when the previous connector instance is shut down. > > What is the best way to stop/halt and restart a Consumer using the Java > API? > > Is it normal that the MBean is not unregistered at shutdown time? > > Thanks, > > -- Tanguy >
