[GitHub] kafka pull request #3667: KAFKA-5606: Review consumer's RequestFuture usage ...
Github user jedichien closed the pull request at: https://github.com/apache/kafka/pull/3667 ---
[GitHub] kafka pull request #3667: [KAFKA-5606] Review consumer's RequestFuture usage...
GitHub user jedichien opened a pull request: https://github.com/apache/kafka/pull/3667 [KAFKA-5606] Review consumer's RequestFuture usage pattern Replacing succeeded, failed and retry with a status method returning an enum with 'SUCCEEDED', 'FAILED', 'RETRY' and 'NOT_RETRY' You can merge this pull request into a Git repository by running: $ git pull https://github.com/jedichien/kafka KAFKA-5606 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/3667.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 #3667 commit da4bcbaa90ed2107128914f7d6ca92add6e616db Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-04-27T08:00:20Z change connection refused message from level DEBUG into WARN. commit 1adfd44424f2760def0a648c96129243088ef044 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T08:26:04Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 407b48b83d3acd8e7803bd32e93aa28e48c446a9 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:45:23Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 9c3caa19724606e2e8982ea1c63ce8a480945e73 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:51:01Z revert commit 80dc9358962c85bf7d369dea5fa5e41965071585 Author: JamesChien <jedich...@users.noreply.github.com> Date: 2017-05-03T01:20:56Z remove unused variable commit 0777963ffc452e69eb468e546c7e4881ecff4cde Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-05T09:01:46Z replace 'KStreamPeek#KStreamPeekProcessor' with PrintForeachAction commit 65eddb227ddc003e71e1e79a2d378014d652566c Author: jameschien <jamesch...@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 <jamesch...@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 <jamesch...@staff.ruten.com.tw> Date: 2017-05-08T10:07:04Z add final and remove unnecessary code commit bfbcced3969701e525d6109372ff6cbedbd4 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-08T10:13:50Z add final to local variable commit 62972990a84c4a77c7ca8c3eba6028ddb3f73990 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-17T01:34:34Z add KStreamPrint to print data message with PrintForeachAction commit 57784600657c71ed4736704bf07af8060e79b74f Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-17T01:45:09Z add KStreamPrint to print data message with PrintForeachAction commit 83101ff29ffe52735883e8b71f61176388724229 Author: JamesChien <jedich...@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, Serde) and KStream.print(KeyValueMapper<K, V, String>, Serde, Serde, String streamName). commit c40db4fa6e0d0bc99e339f1f5749ee73e83a2ec8 Author: jedichien <james.chain1...@gmail.com> Date: 2017-05-23T02:17:51Z fix conflict commit e72a6c6fabd4c2139155a8927f7d2bc851914479 Author: JamesChien <james.chain1...@gmail.com> Date: 2017-05-23T02:28:21Z Merge branch 'trunk' into KAFKA-4830 commit 3fe6a8ba513287755df7fc51a1d7b1e59aba0a23 Author: jedichien <james.chain1...@gmail.com> Date: 2017-05-23T02:29:53Z remove whitespace commit 28c8ccdb18757e7a832d3fe83e53b45e049bf6f9 Author: jedichien <james.chain1...@gmail.com> Date: 2017-05-23T02:38:19Z I forget to remove this code when I solve confliction commit 03a3f906d6eba9ded70af4fcd21638346822fc7b Author: jedichien <james.chain1...@gmail.com> Date: 2017-05-23T02:41:14Z I forget to remove this code when I solve confliction commit b858b0ff52a4881a5f5146430122219f61bfefb3 Author: jedichien <james.chain1...@gmail.com> Date: 2017-06-23T04:21:17Z [KIP-160] Augment KStream.print() and KStream.writeAsText() to allow users pass in extra parameters in the printed string. commit 5245ed9e79e32138cda5f198b644a333e113715c Author: jedichien <james.chain1...@gmail.com> Date: 2017-06-23T04:22:33Z Merge remote-tracking branch 'origin/KAFKA-4830' into KAFKA-4830 commit ce8d16ed650d3649cf20763021f4983f699365fc Author: jedichien <james.chain1..
[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, Serde)` 4. `KStream#print(KeyValueMapper<K, V, String>, Serde, Serde, 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 <jamesch...@staff.ruten.com.tw> Date: 2017-04-27T08:00:20Z change connection refused message from level DEBUG into WARN. commit 1adfd44424f2760def0a648c96129243088ef044 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T08:26:04Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 407b48b83d3acd8e7803bd32e93aa28e48c446a9 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:45:23Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 9c3caa19724606e2e8982ea1c63ce8a480945e73 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:51:01Z revert commit 80dc9358962c85bf7d369dea5fa5e41965071585 Author: JamesChien <jedich...@users.noreply.github.com> Date: 2017-05-03T01:20:56Z remove unused variable commit 0777963ffc452e69eb468e546c7e4881ecff4cde Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-05T09:01:46Z replace 'KStreamPeek#KStreamPeekProcessor' with PrintForeachAction commit 65eddb227ddc003e71e1e79a2d378014d652566c Author: jameschien <jamesch...@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 <jamesch...@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 <jamesch...@staff.ruten.com.tw> Date: 2017-05-08T10:07:04Z add final and remove unnecessary code commit bfbcced3969701e525d6109372ff6cbedbd4 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-08T10:13:50Z add final to local variable commit 62972990a84c4a77c7ca8c3eba6028ddb3f73990 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-17T01:34:34Z add KStreamPrint to print data message with PrintForeachAction commit 57784600657c71ed4736704bf07af8060e79b74f Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-17T01:45:09Z add KStreamPrint to print data message with PrintForeachAction commit 83101ff29ffe52735883e8b71f61176388724229 Author: JamesChien <jedich...@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, Serde) and KStream.print(KeyValueMapper<K, V, String>, Serde, Serde, 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 infrastruct...@apache.org or file a JIRA ticket with INFRA. ---
[GitHub] kafka pull request #2955: Replace KeyValuePrinter and KStreamForeach with KS...
GitHub user jedichien opened a pull request: https://github.com/apache/kafka/pull/2955 Replace KeyValuePrinter and KStreamForeach with KStreamPeek I remove `KeyValuePrinter` and `KStreamForeach` two class, then implements them by `KStreamPeek`. So, now `KStreamPeek` can do `KeyValuePrinter` and `KStreamForeach` job. You can merge this pull request into a Git repository by running: $ git pull https://github.com/jedichien/kafka trunk Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/2955.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 #2955 commit da4bcbaa90ed2107128914f7d6ca92add6e616db Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-04-27T08:00:20Z change connection refused message from level DEBUG into WARN. commit 1adfd44424f2760def0a648c96129243088ef044 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T08:26:04Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 407b48b83d3acd8e7803bd32e93aa28e48c446a9 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:45:23Z replace KeyValuePrinter and KStreamForeach with KStreamPeek commit 9c3caa19724606e2e8982ea1c63ce8a480945e73 Author: jameschien <jamesch...@staff.ruten.com.tw> Date: 2017-05-02T10:51:01Z revert --- 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. ---
[GitHub] kafka pull request #2924: change connection refused message from level DEBUG...
Github user jedichien closed the pull request at: https://github.com/apache/kafka/pull/2924 --- 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. ---
