Hi John,
Thanks for explanation.
Yes, indeed, this is happening in my app. I also checked my state store
behind the output topic and there is always the latest value.
Is it possible that TestTopologyDriver can fully mimic Kafka Streams? Maybe
somehow records in the output topic can be ordered by
Hi Adam,
I haven't looked into your project yet, but just wanted to mention
this to see if it explains your observations.
TopologyTestDriver processes every input record fully and
synchronously. So, when you pipe an input record in, it traverses all
internal processing, including intermediate top
