Status

Current state: Under Discussion

...

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

Motivation

As for now, KStream#print leads to a predefined output where key and value are printed with comma separation.
KAFKA-4830 suggests to extend print in a way that it takes KeyValueMapper as a parameter.
This will allow a user to change outputs according to the users demand.

Public Interfaces

The affected interface is KStream, which needs to be extended with another overloaded version of print:

void print(final Serde<K> keySerde,
           final Serde<V> valSerde,
           final String streamName,
           final KeyValueMapper<K, V, String> mapper);

Proposed Changes

See pull request GH-2669.
This PR contains a discussion regarding KAFKA-4830 as well as KAFKA-4772.

...