Re: Leader election strategy

Hi Pierre, Try using kafka-reassign-partitions.sh to reassign partitions to different replicas you like. ref: https://kafka.apache.org/documentation/#basic_ops_automigrate Luke On Mon, Nov 14, 2022 at 3:55 PM Pierre Coquentin wrote: > Hello, > We have a Kafka cluster (2.4.1) with a replicatio

Re: Connection issue

Hi shikha, I think you should ask in Spark community. Thanks Luke On Tue, Nov 15, 2022 at 3:17 AM shikha sharma wrote: > Hello, > > I am trying to connect to kafka using this command: > orderRawData = spark.readStream \ > .format("kafka") \ > .option("kafka.bootstrap.servers", "18.211.

Connection issue

Hello, I am trying to connect to kafka using this command: orderRawData = spark.readStream \ .format("kafka") \ .option("kafka.bootstrap.servers", "18.211.252.152:9092") \ .option("startingOffsets","earliest") \ .option("failOnDataLoss", "false") \ .option("subscribe", "real-ti

Re: Confluent Schema Registry - auto.register.schemas

hello All - checking to see if anyone has updates on this. tia! On Fri, Nov 11, 2022 at 1:55 PM karan alang wrote: > Hello All, > > ref stackoverflow : > https://stackoverflow.com/questions/74396652/confluent-schema-registry-why-is-auto-register-schemas-not-applicable-at-schem > > --- > > I've

Kafka and Zookeeper FIPS SASL connection

Hi, In my environment I have configured FIPS java, Zookeeper to work with SASL and a Kafka broker to connect to Zookeeper with SASL I noticed that if FIPS is enabled, kafka cannot connect and there is an error "ERROR SASL authentication with Zookeeper Quorum member failed. (org.apache.zooke