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

Question

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

Opened this issue 5 years ago · 1 comments

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.

Answer 1 · 2019-08-09T13:26:38.000Z

resolved with v2.1.0