You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "lsj (Jira)" <ji...@apache.org> on 2020/03/30 10:54:00 UTC
[jira] [Commented] (KAFKA-4629) Per topic MBeans leak
[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070879#comment-17070879 ]
lsj commented on KAFKA-4629:
----------------------------
I tested 0.10.2 and 1.0.1 . encountered the same problem. broker cluster with three borkers,i delete all the topics,but MBeans could not be removed as expected.
> Per topic MBeans leak
> ---------------------
>
> Key: KAFKA-4629
> URL: https://issues.apache.org/jira/browse/KAFKA-4629
> Project: Kafka
> Issue Type: Bug
> Components: metrics
> Affects Versions: 0.10.0.1
> Reporter: Alberto Forti
> Priority: Minor
>
> Hi,
> 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: kafka.server:type=BrokerTopicMetrics,name=TotalProduceRequestsPerSec,topic=dw_06b5f828-e452-4e22-89c9-67849a65603d
> 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 dw_fe8ff14b-aa9b-4f24-9bc1-6fbce15d20d2
> 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: 0.10.0.1 (haven't tried other versions)
> Thanks,
> Alberto
--
This message was sent by Atlassian Jira
(v8.3.4#803005)