Resource leak in KafkaProducer when reset to initial state in a CR

Question

Resource leak in KafkaProducer when reset to initial state in a CR

Opened this issue 5 years ago · 2 comments

When the KafkaProducer operator is reset to initial state, a new ProducerClient instance is created. It instantiates a new MetricsFetcher, which consumes a thread from the operator's thread pool.

The thread of the old ProducerClient.metricsFetcher keeps running referencing the old metricsFetcher instance.

Answer 1 · 2019-06-25T12:16:49.000Z

Bug detected when #164 has been tested.

Answer 2 · 2019-08-09T13:26:21.000Z

resolved with v2.1.0