Hi All, I would like to start the discussion on KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-456%3A+Helper+classes+to+make+it+simpler+to+write+test+logic+with+TopologyTestDriver There is also related KIP adding methods to TopologyTestDriver: https://cwiki.apache.org/confluence/display/KAFKA/KIP-451%3A+Make+TopologyTestDriver+output+iterable I added those new Iterable based methods to this TestOutputTopic even not tested those myself yet. So this version contains both my original List and Map based methods and these new one. Based on the discussion some of these can be dropped, if those are seen as redundant. Best Regards, Jukka