Fake Kafka client's reset! method working fine but producer's buffer not emptied at each message/s delivery

[enonnai]

Fake Kafka client's reset! method working fine but producer's buffer not emptied at each message/s delivery

Hello all,

As mentioned in the title, I am using the 'reset!` method of the Kafe Kafka instance, though one still needs to set a new producer at every new test, as the producer's buffer is not cleared after message/s delivery.

Example:
A message gets delivered in test nr 1. Message count is 1.
For test nr 2, we have another message to deliver, but message count is 2 because the producer will deliver 1 message from test nr 2, PLUS the other message from test 1, as it lingers in the producer's buffer. And so on so forth.

Would be great to hear back from you on this one, thanks for the attention!

Cristina