THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
"[" + this.streamName + "]: " + mapper.apply(keyToPrint, valueToPrint) |
Public Interfaces
...
Expanding KStream#print() which also need to be extended another version of print.
| Code Block | ||||
|---|---|---|---|---|
| ||||
void print(final KeyValueMapper<? super K, ? super V, String> mapper);
void print(final KeyValueMapper<? super K, ? super V, String> mapper, final String streamName);
void print(final KeyValueMapper<? super K, ? super V, String> mapper, final Serde<K> keySerde, final Serde<V> valSerde);
void print(final KeyValueMapper<? super K, ? super V, String> mapper, final Serde<K> keySerde, final Serde<V> valSerde, final String streamName); |
Proposed Changes
A straightforward first pass is on GitHub PR#3085.
...