Alberto Forti created KAFKA-4629:

             Summary: Per topic MBeans leak
                 Key: KAFKA-4629
             Project: Kafka
          Issue Type: Bug
    Affects Versions:
            Reporter: Alberto Forti
            Priority: Minor


In our application we create and delete topics dynamically. Most of the times 
when a topic is deleted the related MBeans are not deleted. Example of MBean: 

Also, deleting a topic often produces (what I think is) noise in the logs at 
WARN level. One example is:
WARN  PartitionStateMachine$DeleteTopicsListener:83 - [DeleteTopicsListener on 
1]: Ignoring request to delete non-existing topics 

Easy reproducible with a basic Kafka cluster with two brokers, just create and 
delete topics few times. Sometimes the MBeans for the topic are deleted and 
sometimes are not.

I'm creating and deleting topics using the AdminUtils class in the Java API:
AdminUtils.deleteTopic(zkUtils, topicName);
AdminUtils.createTopic(zkUtils, topicName, partitions, replicationFactor, 
topicConfiguration, kafka.admin.RackAwareMode.Enforced$.MODULE$);

Kafka version: (haven't tried other versions)


This message was sent by Atlassian JIRA

Reply via email to