Guozhang Wang created KAFKA-4830:
------------------------------------
Summary: Augment KStream.print() to allow users pass in extra
parameters in the printed string
Key: KAFKA-4830
URL: https://issues.apache.org/jira/browse/KAFKA-4830
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Guozhang Wang
Today {{KStream.print}} use the hard-coded result string as:
{code}
"[" + this.streamName + "]: " + keyToPrint + " , " + valueToPrint
{code}
And some users are asking to augment this so that they can customize the output
string as {{KStream.print(KeyValueMapper<K, V, String>):
{code}
"[" + this.streamName + "]: " + mapper.apply(keyToPrint, valueToPrint)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)