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', &#x
Github user jedichien closed the pull request at:
https://github.com/apache/kafka/pull/3667
---
GitHub user jedichien opened a pull request:
https://github.com/apache/kafka/pull/2924
change connection refused message from level DEBUG into WARN.
If broker is down, we supply logging message to let user know
`java.net.ConnectException: Connection refused` but not should be 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
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
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)`.
So I add the following methods
