[KAFKA-4772] Exploit #peek to implement #print() and other methods

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.11.0.0
• Component/s: streams
• Labels: beginner newbie
• Assignee: james chien
• Reporter: Matthias J. Sax
• Created: 16/Feb/17 17:37
• Updated: 30/Jan/18 04:42
• Resolved: 17/May/17 18:15

Description

From: https://github.com/apache/kafka/pull/2493#pullrequestreview-22157555

Things that I can think of:

• print / writeAsTest can be a special impl of peek; KStreamPrint etc can be removed.
• consider collapse KStreamPeek with KStreamForeach with a flag parameter indicating if the acted key-value pair should still be forwarded.

Issue Links

• blocks: KAFKA-4830 Augment KStream.print() to allow users pass in extra parameters in the printed string
• is related to: KAFKA-4720 Add KStream.peek(ForeachAction<K,V>)
• relates to: KAFKA-5267 Simplify KStreamPrint using RichFunctions
• links to: GitHub Pull Request #2669
• links to: GitHub Pull Request #2669
• links to: GitHub Pull Request #2703
• links to: GitHub Pull Request #2703
• links to: GitHub Pull Request #2704
• links to: GitHub Pull Request #2704
• links to: GitHub Pull Request #2955