Matthias J. Sax created KAFKA-4772:
--------------------------------------
Summary: Exploit #peek to implement #print() and other methods
Key: KAFKA-4772
URL: https://issues.apache.org/jira/browse/KAFKA-4772
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Matthias J. Sax
Priority: Minor
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.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
