Re: kafka streams partition assignor strategy for version 2.5.1 - does it use sticky assignment

2023-04-14 Thread Pushkar Deole
Any inputs on below query? On Wed, Apr 12, 2023 at 2:22 PM Pushkar Deole wrote: > Hi All, > > We are using version 2.5.1 of kafka-streams with 3 application instances > deployed as 3 kubernetes pods. > It consumes from multiple topics, each with 6 partitions. > I would like to know if streams us

Kafka SSL Error

2023-04-14 Thread Mehmet Can YILMAZ
Hi, I'm trying to start kafka services using SASL_SSL. I am using SCRAM as the authentication method. But I am getting error. Error details are attached. org.apache.kafka.common.KafkaException: org.apache.kafka.common.config.ConfigException: Invalid value javax.net.ssl.SSLHandshakeException: No

Re: Facing new leader election issues in zookeeper-less kafka cluster having version 3.3.2

2023-04-14 Thread Kunal Jadhav
Thanks Divij, I will check further. --- Thanks & Regards, Kunal Jadhav On Fri, Apr 14, 2023 at 4:25 PM Divij Vaidya wrote: > Hey Kunal > > We would need more information to debug your scenario since there are no > known bugs (AFAIK) in 3.3.2 associated with leader election. > > At a very high

Re: Facing new leader election issues in zookeeper-less kafka cluster having version 3.3.2

2023-04-14 Thread Divij Vaidya
Hey Kunal We would need more information to debug your scenario since there are no known bugs (AFAIK) in 3.3.2 associated with leader election. At a very high level, the ideal sequence of events should be as follows: 1. When the existing leader shuts down, it will stop sending requests for heartb

Facing new leader election issues in zookeeper-less kafka cluster having version 3.3.2

2023-04-14 Thread Kunal Jadhav
Hello All, We have implemented 3 brokers cluster on a single node server in the kubernetes environment, which is a zookeeper-less cluster having kafka version 3.32. And facing one issue like when the existing leader broker gets down then the new leader is not elected. We have faced this issue seve