search

IBMStreams / streamsx.kafka

Repository for integration with Apache Kafka
https://ibmstreams.github.io/streamsx.kafka/
Apache License 2.0
13 stars 9 forks source link

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

Closed ghost closed 5 years ago

ghost commented 5 years ago

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.

ghost commented 5 years ago

Bug detected when #164 has been tested.

ghost commented 5 years ago

resolved with v2.1.0