[ https://issues.apache.org/jira/browse/KAFKA-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060039#comment-17060039 ]
Sönke Liebau commented on KAFKA-9609: ------------------------------------- If that is something that you would like to work on [~satish.gudl...@gmail.com] please feel free to create a KIP and start a discussion on this topic. I don't think the code changes should be too complex, but it would be a change of public-facing behavior, so definitely need a KIP before it could be implemented. Let me know if you have any questions around the process, happy to help!! > Memory Leak in Kafka Producer > ----------------------------- > > Key: KAFKA-9609 > URL: https://issues.apache.org/jira/browse/KAFKA-9609 > Project: Kafka > Issue Type: Bug > Components: clients, producer > Affects Versions: 2.4.0 > Reporter: Satish > Assignee: Sönke Liebau > Priority: Major > > org.apache.kafka.clients.producer.internals.Sender adds Topic Metrics for > every topic that we are writing messages to but it never been cleaned up > until we close the producer. > This is an issue if we use single producer and have more number of Dynamic > topics (eg: ~ 500 topics per hour) and writing messages to them. As this > Metrics map is getting accumulated for every topic, over a period of time we > notice the memory usage gets increased gradually. > It can be easily reproducible by writing messages to the more # of dynamic > topics using the same KafkaProducer from apache kafka client libraries or > KafkaTemplate from Spring. > -- This message was sent by Atlassian Jira (v8.3.4#803005)