...

Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]

JIRA: KAFKA-10578 

PR: PR-9381

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

stream.toTable()
		.toStream((key, previousValue, newValue) -> newValue - (previousValue != null ? previousValue : 0));

The proposal can be seen in https://github.com/apache/kafka/pull/9381

Compatibility, Deprecation, and Migration Plan

...