Hi, I was testing the KafkaSinglePortExactlyOnceOutputOperator and I see below error in case of operator fails. This is not reproducible every time but occurs more than 50% of the time. I tried testing it with single operator instance, with multiple partitions and parallel partitions but i couldn't get the pattern since failure doesn't happen always.
Is there anything I missing out during operator setup or cleanup Regards Vivek -- Sent from: http://apache-apex-users-list.78494.x6.nabble.com/