Aleksandr Savonin created FLINK-40912:
-----------------------------------------

             Summary: ExactlyOnceKafkaWriter never closes the AdminClient it 
creates for the listing abort strategy
                 Key: FLINK-40912
                 URL: https://issues.apache.org/jira/browse/FLINK-40912
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
            Reporter: Aleksandr Savonin


ExactlyOnceKafkaWriter lazily creates an AdminClient in getAdminClient() but 
never closes it. close() closes the current producer, the producer pool and the 
backchannel, and calls super.close(), but the adminClient field is not part of 
the closeAll(...) chain, and nothing else closes it.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to