Paolo Patierno created KAFKA-5684:
-------------------------------------
Summary: KStreamPrintProcessor as customized KStreamPeekProcessor
Key: KAFKA-5684
URL: https://issues.apache.org/jira/browse/KAFKA-5684
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Paolo Patierno
Assignee: Paolo Patierno
Priority: Minor
Hi,
the {{KStreamPrintProcessor}} is implemented from scratch (from the
{{AbstractProcessor}}) and the same for the related supplier.
It looks to me that it's just a special {{KStreamPeekProcessor}} with
forwardDownStream to false and that allows the possibility to specify Serdes
instances used if key/values are bytes.
At same time used by a {{print()}} method it provides a fast way to print data
flowing through the pipeline (while using just {{peek()}} you need to write the
code).
I think that it could be useful to refactoring the {{KStreamPrintProcessor}} as
derived from the {{KStreamPeekProcessor}} customizing its behavior.
Thanks,
Paolo.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
