on reset() the KafkaProducerOperator should instantiate a new producer instance

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

on reset() the KafkaProducerOperator should instantiate a new producer instance #164

Closed ghost closed 5 years ago

ghost commented 5 years ago

The KafkaProducer operator creates a new producer on resetToInitialState(). The same should happen on reset(). For the transactional producer, the ongoing transaction must be aborted before.

Need to check, if transactional.id must be the same with a new producer instance.

ghost commented 5 years ago

resolved with v2.1.0