Re: [External] Re: Dead broker in ISR

Hi all, An update about this. Having a dead broker is the ISR doesn't seem by-design. I added an issue about this, because it is actually causing exceptions: Uncaught exception in scheduled task 'isr-expiration' (kafka.utils.KafkaScheduler)

Re: Subject: [VOTE] 2.4.1 RC0

+1 (binding) Download kafka_2.13-2.4.1 and verified signature, ran quickstart, everything looks good. Thanks for running this release, Bill! -David On Wed, Mar 4, 2020 at 6:06 AM Eno Thereska wrote: > Hi Bill, > > I built from source and ran unit and integration tests. They passed. > There

Writing Integration test with Embedded Kafka

I am trying to write an integration test using Embedded Kafka but I keep getting NullPointerException. My test case is very simple. It has following steps: 1. Read a JSON file & write messages to an inputTopic. 2. Perform a 'readStream' operation. 3. Do a 'select' on the Stream. This thro

Adding additional nodes to Existing ZK cluster

Team, I currently have a 1 node ZK cluster and which is working fine. Now I want to add additional 2 more nodes to ZK cluster. Could you please provide best practice so I don't loose existing data? Thanks Bibin John