kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Paolo Patierno (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5684) KStreamPrintProcessor as customized KStreamPeekProcessor
Date Tue, 01 Aug 2017 12:52:00 GMT
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

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.


This message was sent by Atlassian JIRA

View raw message