[jira] [Resolved] (KAFKA-9351) Higher count in destination cluster using Kafka MM2

[ https://issues.apache.org/jira/browse/KAFKA-9351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan resolved KAFKA-9351. - Resolution: Information Provided > Higher count in destination cluster using Kafka MM2 >

Re: [DISCUSS] KIP-563: Add 'tail -n' feature for ConsoleConsumer

Hi, I'm new here, but I just read this and have implemented similar functionality for our cli tool (https://github.com/deviceinsight/kafkactl). In order to get a tail on topic level we fetch the last n messages from all partitions but only keep the latest n messages according to message

Re: [DISCUSS] : KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Thanks, Navinder, The Param object looks a bit different than I would have done, but it certainly is explicit. We might have to deprecate those particular factory methods and move to a builder pattern if we need to add any more options in the future, but I’m fine with that possibility. The

Re: [DISCUSS] : KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance

I have made some edits in the KIP, please take another look. It would be great if we can push it in 2.5.0. ~Navinder On Sunday, January 19, 2020, 12:59 AM, Navinder Brar wrote: Sure John, I will update the StoreQueryParams with static factory methods. @Ted, we would need to create taskId

[DISCUSS] KIP-563: Add 'tail -n' feature for ConsoleConsumer

Hi All, I'd like to start a discussion on KIP-563 which is to add "tail -n" capability for ConsumerConsole tool. Please check https://cwiki.apache.org/confluence/display/KAFKA/KIP-563%3A+Add+%27tail+-n%27+feature+for+ConsoleConsumer for more details. Any feedbacks or comments are welcomed.

[jira] [Created] (KAFKA-9455) Consider using TreeMap for In-memory stores of Streams

Guozhang Wang created KAFKA-9455: Summary: Consider using TreeMap for In-memory stores of Streams Key: KAFKA-9455 URL: https://issues.apache.org/jira/browse/KAFKA-9455 Project: Kafka Issue

Jenkins build is back to normal : kafka-trunk-jdk11 #1096

See

Jenkins build is back to normal : kafka-trunk-jdk8 #4172

See

Re: [VOTE] KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions

Hi All, With +1 binding votes from Guozhang, Matthias and Bill and non-binding +1 votes from Mitch, and M. Manna, the vote passes Thanks all, anna On Wed, Jan 15, 2020 at 9:54 PM Anna McDonald wrote: > > Done. Thanks for pointing that out. > > anna > > On Wed, Jan 15, 2020 at 8:52 PM Guozhang