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)

Reply via email to