Agreed. Currently, no actual buffering is implemented. Attempts to do anything but immediately emit will throw an exception. This is verified by the processor test.
In the next PR, I implement buffering, and I have the integration tests for the different strategies there. [ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
