I can't successfully test my processing application which require
EXACTLY_ONCE processing guarantee using the new TopologyTestDriver. I
always get the following exception:
java.lang.IllegalStateException: MockProducer hasn't been initialized
The tests all work fine as soon as I set PROCESSING_GUARANTEE_CONFIG to
Am I doing something wrong?
Kafka developpers can reproduce this by adding:
to line 88 of TopologyTestDriverTest: