Subject: [VOTE] 2.8.0 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 2.8.0. This is a major release that includes many new features, including: * Early-access release of replacing Zookeeper with a self- managed quorum * Add Describe Cluster API * Support

Kafka Stream: State replication seems unpredictable.

Hey, We have the following setup in our infrastructure. 1. Kafka - 2.5.1 2. Apps use kafka streams `org.apache.kafka` version 2.5.1 library 3. Low level processor API is used with *atleast-once* semantics 4. State stores are *in-memory* with *caching disabled* and *changelog

Re: Kafka Connect Distributed Mode Issues

Yeah, looks like it's an issue with the plugin. I don't have any experience of it, sorry. On Tue, 6 Apr. 2021, 12:32 am Himanshu Shukla, wrote: > bootstrap.servers=b-1:9092,b-2:9092 > group.id=connect-cluster > key.converter=org.apache.kafka.connect.json.JsonConverter >

Re: MirrorMaker 2 and Negative Lag

Hello Frank, Happy to look into it. Do you mind to open a jira ticket and put your and Alan's observations into it, then assign it to me (also would be great to refer this link)? I will take some time to reproduce it when available. Thanks On 2021/03/30 19:08:56, Frank Yi wrote: > Hey