[KAFKA-4830] Augment KStream.print() to allow users pass in extra parameters in the printed string

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: streams
• Labels: kip newbie
• Assignee: james chien
• Reporter: Guozhang Wang
• Created: 01/Mar/17 19:59
• Updated: 11/Sep/17 16:09
• Resolved: 20/Jul/17 13:48

Description

Today KStream.print use the hard-coded result string as:

"[" + this.streamName + "]: " + keyToPrint + " , " + valueToPrint

And some users are asking to augment this so that they can customize the output string as KStream.print(KeyValueMapper<K, V, String>) :

"[" + this.streamName + "]: " + mapper.apply(keyToPrint, valueToPrint)

Original KIP-132: https://cwiki.apache.org/confluence/display/KAFKA/KIP-132%3A+Augment+KStream.print+to+allow+extra+parameters+in+the+printed+string
Duplicating KIP-160: https://cwiki.apache.org/confluence/display/KAFKA/KIP-160%3A+Augment+KStream.print%28%29+to+allow+users+pass+in+extra+parameters+in+the+printed+string

Issue Links

• is blocked by: KAFKA-4772 Exploit #peek to implement #print() and other methods
• links to: GitHub Pull Request #3085
• mentioned in: Page Loading...