[jira] [Created] (FLINK-9287) KafkaProducer011 seems to leak threads when not in exactly-once mode

[Shang Yuanchun (Jira)]

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)