[FLINK-34693] Memory leak in KafkaWriter

• Type: Bug
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Affects Version/s: kafka-3.1.0, kafka-3.0.2
• Component/s: Connectors / Kafka
• Assignee: Unassigned
• Reporter: Stefan Richter
• Created: 15/Mar/24 09:31
• Updated: 21/Mar/24 02:28

Description

KafkaWriter is keeping objects in Dequeue of closeables (producerCloseables) that are never removed so that the can be GC’ed.

From heap dump:!04599375-f923-4d1a-8d68-9e17e54b363c#media-blob-url=true&id=9d1e022e-8762-45b3-877b-d298ec956078&collection=&contextId=870337&height=306&width=2284&alt=!