You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by jedichien <gi...@git.apache.org> on 2017/05/18 09:21:20 UTC

[GitHub] kafka pull request #3085: KAFKA-4830: Augment KStream.print() to allow users...

GitHub user jedichien opened a pull request:

    https://github.com/apache/kafka/pull/3085

    KAFKA-4830: Augment KStream.print() to allow users pass in extra parameters in the printed string

    I extend `KStream#print()` to `KStream#print(KeyValueMapper<K, V, String>)`.
    So I add the following methods :
    1. `KStream#print(KeyValueMapper<K, V, String>)`
    2. `KStream#print(KeyValueMapper<K, V, String>, String streamName)`
    3. `KStream#print(KeyValueMapper<K, V, String>, Serde<K>, Serde<V>)`
    4. `KStream#print(KeyValueMapper<K, V, String>, Serde<K>, Serde<V>, String streamName)`


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/jedichien/kafka KAFKA-4830

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/kafka/pull/3085.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 #3085
    
----
commit da4bcbaa90ed2107128914f7d6ca92add6e616db
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-04-27T08:00:20Z

    change connection refused message from level DEBUG into WARN.

commit 1adfd44424f2760def0a648c96129243088ef044
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-02T08:26:04Z

    replace KeyValuePrinter and KStreamForeach with KStreamPeek

commit 407b48b83d3acd8e7803bd32e93aa28e48c446a9
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-02T10:45:23Z

    replace KeyValuePrinter and KStreamForeach with KStreamPeek

commit 9c3caa19724606e2e8982ea1c63ce8a480945e73
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-02T10:51:01Z

    revert

commit 80dc9358962c85bf7d369dea5fa5e41965071585
Author: JamesChien <je...@users.noreply.github.com>
Date:   2017-05-03T01:20:56Z

    remove unused variable

commit 0777963ffc452e69eb468e546c7e4881ecff4cde
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-05T09:01:46Z

    replace 'KStreamPeek#KStreamPeekProcessor' with PrintForeachAction

commit 65eddb227ddc003e71e1e79a2d378014d652566c
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-05T09:03:59Z

    revert and will open new issue to discuss whether to keep this or not

commit 08f37fb99e16c701f293d59d9d12a8f039e9613e
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-05T09:05:00Z

    Merge branch 'trunk' of https://github.com/jedichien/kafka into trunk
    
    replace 'KStreamPeek#KStreamPeekProcessor' with PrintForeachAction

commit 3371b13aec71d80e097212820b0beef625948f37
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-08T10:07:04Z

    add final and remove unnecessary code

commit bfbcced3969701e525d61099999372ff6cbedbd4
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-08T10:13:50Z

    add final to local variable

commit 62972990a84c4a77c7ca8c3eba6028ddb3f73990
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-17T01:34:34Z

    add KStreamPrint to print data message with PrintForeachAction

commit 57784600657c71ed4736704bf07af8060e79b74f
Author: jameschien <ja...@staff.ruten.com.tw>
Date:   2017-05-17T01:45:09Z

    add KStreamPrint to print data message with PrintForeachAction

commit 83101ff29ffe52735883e8b71f61176388724229
Author: JamesChien <je...@users.noreply.github.com>
Date:   2017-05-18T09:14:08Z

    Augment KStream.print() to allow users pass in extra parameters in the printed string. I extend print() to KStream.print(KeyValueMapper<K, V, String>), KStream.print(KeyValueMapper<K, V, String>, String streamName), KStream.print(KeyValueMapper<K, V, String>, Serde<K>, Serde<V>) and KStream.print(KeyValueMapper<K, V, String>, Serde<K>, Serde<V>, String streamName).

----


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] kafka pull request #3085: KAFKA-4830: Augment KStream.print() to allow users...

Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:

    https://github.com/apache/kafka/pull/3085


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---