Question about moving kafka brokers between AZs in AWS

2024-06-06 Thread Soham Chakraborty
Hello, Here is the scenario. We have a kafka/zookeeper ensemble, where kafka and zookeeper are installed on the same node (instance). There are three zk nodes and two kafka nodes. In other words, out of the three zk nodes, kafka is present in two. Now, these two kafka brokers are in different AZ

I want to subscribe

2024-06-06 Thread outof2023
I want to subscribe

Re: Console consumer crashing

2024-06-06 Thread Patrick G. Heck
I never resolved this, but it was near the end of an engagement so it got punted. Is this something anyone else can reproduce? I worry that some prior use of kafka has interfered. I tried wiping out zookeeper and /tmp/kafka_logs ... is there anywhere else that could be retaining something that is

Re: Compatibility with jdk 21

2024-06-06 Thread Divij Vaidya
Apache Kafka supports building with JDK 21 with version >= 3.7.0 https://issues.apache.org/jira/browse/KAFKA-15485 is the reference ticket. -- Divij Vaidya On Thu, Jun 6, 2024 at 6:46 AM Sahil Sharma D wrote: > Hi team, > > Which version of Kafka is compatible with jdk 21 or is there any > c

How to avoid deletion of data when replicating with the Mirrormaker on switchover in Active and Passive DC

2024-06-06 Thread Vijay Chandhar Bachala
Currently I am trying out a Kafka (3.7 version) deployment 1*1 [One Active (say DC1 ) and One Passive(say DC2)] . And using MIrrormaker-2 for replicating Kafka data between Active and Passive Data Centers. Here Kafka and Mirrormaker are executing in Docker Container and volume mounting only with th

PlainText protocol and ACL

2024-06-06 Thread Franck
Hello, I'm working on StandardAcl class in Kafka, I can run all the test successfully in metadat:test, BUT, when playing "gradlew test" it is failing mainly on test based with plaintext protocol. I'm investigating and looking for an answer of the question : how is build the KafkaPrincipal in