Kraft - Adding new controllers in production

Hello! I'm wondering if there's a right way to add new controllers to an already existing cluster without downtime. I've tried the following: I have three controllers joined in a cluster then one by one I change configuration to 4 voters, stop controller, delete quorum-state, start controller. Whe

Python client failed to connect secured Kafka: SSL handshake failed: error:1408F10B:SSL routines:ssl3_get_record:wrong version number

Hi Kafka Team Recently I moved Kafka cluster from CentOS8 to UbuntuServer20.04, same Kafka version(2.13-3.0.0), same Kafka configuration(check below), same JDK(openjdk-11-jdk) in server, but I get python client failed to connect. # SASL-SSL security.inter.broker.protocol=SASL_SSL sasl.enabled.me

Re: Setting up the CooperativeStickyAssignor in Java

Hi Liam, I've gotten the cooperative sticky assignor to work with the latest fs2-kafka wrapper. There was a bug in my code where the `.parJoinUnbounded` which processes the streams needed to move out 1 scope of execution to pull in the notification message stream. It's possible that the 2.4.0 vers