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)