Christopher Ng created FLINK-9287:
-------------------------------------
Summary: KafkaProducer011 seems to leak threads when not in
exactly-once mode
Key: FLINK-9287
URL: https://issues.apache.org/jira/browse/FLINK-9287
Project: Flink
Issue Type: Bug
Components: Kafka Connector
Affects Versions: 1.4.2
Reporter: Christopher Ng
{{KafkaProducer011}} appears to be leaking {{kafka-producer-network-thread
}}threads. As far as I can tell it happens when it is not in EXACTLY_ONCE
mode, it seems that it creates a {{FlinkKafkaProducer}} but never closes it,
even when the {{FlinkKafkaProducer011}} itself is closed.
I observed this when running a local cluster and submitting and then cancelling
a job, a lot of kafka threads were left alive afterwards.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
