Compare https://issues.apache.org/jira/browse/KAFKA-6323 and the corresponding PR for more details about punctuation semantics. `TopologyTestDriver` should not work differently (if it does, it's a bug in the test driver -- behavior must be the same to allow for unit testing -- would be bad if it would behave differently).
About the second point: yes, something like this. I did not think this through. Maybe it's also "good enough" to have something more coarse grained for first release. Going with "manual punctuation" with "process" might also be a good first approach -- might still be better than `1ms` punctuation from an overhead point of view (of course, depends on the throughput... 1ms == 1000 records/second/task...) [ Full content available at: https://github.com/apache/kafka/pull/5693 ] This message was relayed via gitbox.apache.org for [email protected]
