GitHub user ppatierno opened a pull request:
https://github.com/apache/kafka/pull/3636
KAFKA-5684: KStreamPrintProcessor as customized KStreamPeekProcessor
This PR is intended for having KStreamPrint derived from KStreamPeek and
avoiding the "instance of" check on byte[ ] every process call.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ppatierno/kafka kafka-5684
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3636.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3636
----
commit a516a08bf22cdd53feb4ada50c73dc5a08715b74
Author: Paolo Patierno <ppatie...@live.com>
Date: 2017-08-07T12:55:16Z
Refactored KStreamPrint as derived from KStreamPeek
Removed the "instance of" check for byte[] in every KStreamPrint process,
it's up to a default mapper now
Updated KStreamPrint tests adapting to the new internal structure for
KStreamPrint and PrintForeachAction
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
