huxi

Unable to set directory or filename dynamically based on the information in a tuple?

3

Hi there, Thanks much for this contrib. We kind of design a log aggregating system which collects logs from sources. The system puts all the log lines into a single...

KAFKA-6649: Should catch OutOfRangeException for ReplicaFetcherThread

5

https://issues.apache.org/jira/browse/KAFKA-6649 `AbstractFetcherThread.processFetchRequest` should catch OffsetOutOfRangeException lest the thread was forcibly stopped. *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message,...

MINOR: UpdateMetadataRequest should be lazily created

9

We should defer to construct UpdateMetadataRequest Builder to the right time when we really need them. *More detailed description of your change, if necessary. The PR title and PR message...