[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34693:
---
Affects Version/s: kafka-3.0.2
kafka-3.1.0
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Attachment: (was: image-2024-03-15-10-30-50-902.png)
> Memory leak in KafkaWriter
>
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Description:
KafkaWriter is keeping objects in Dequeue of closeables
({{{}producerCloseable
[
https://issues.apache.org/jira/browse/FLINK-34693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-34693:
---
Description:
KafkaWriter is keeping instances of {{TwoPhaseCommitProducer}} in Dequeue of
c
