...

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

Proposed Changes

...

Apart from the extension of the interface, the previous implementation of print will be call a new overloaded version thereof. In case no KeyValuemapper is set, null serves as the indicator to use the default output (as described above):

Code Block
language java
@Override public void print(Serde<K> keySerde, Serde<V> valSerde, String streamName) { print(keySerde, valSerde, streamName, null); } @Override public void print(final Serde<K> keySerde, final Serde<V> valSerde, String streamName, final KeyValueMapper<K, V, String> mapper){ ...

 

...