Cluster authorization failed.

[DbIM]

Can't send message to topic (

app.properties spring.kafka.bootstrap-servers=rocket-01.srvs.cloudkafka.com:9094,rocket-02.srvs.cloudkafka.com:9094,rocket-03.srvs.cloudkafka.com:9094 spring.kafka.properties.security.protocol=SASL_SSL spring.kafka.properties.sasl.mechanism=SCRAM-SHA-256 spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule \ required username="login here" password="pass here"; cloudkarafka.topic=topic-default

2022-05-01 18:27:10.274 ERROR 1664 --- [ad | producer-1] o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-1] Aborting producer batches due to fatal error

org.apache.kafka.common.errors.ClusterAuthorizationException: Cluster authorization failed.

[caosDvlp]

Hi! I'm having the same issue

[ivangfr]

Hi, I was facing the same problem.

Btw, I've this project spring-cloud-stream-kafka-multi-topics-cloudkarafka where I've implemented a pair producer / consumer using spring-kafka and another pair using spring-cloud-stream. Both can be used connecting to a CloudKarafka account or connecting to a Kafka-Zookeeper running locally in your machine.

Today, I've tried to upgrade my project, and I've faced with this ClusterAuthorizationException issue that only happens with the spring-kafka producer. Meanwhile, the spring-kafka consumer and the another spring-cloud-stream pair producer / consumer are working fine.

Researching around, I've found this

In short, if you are using spring-kafka and your spring-boot version is >= 2.6, in order to solve ClusterAuthorizationException issue, just set the following in your application.properties

spring.kafka.producer.properties.enable.idempotence=false

[caosDvlp]

Thank you so much! :D

I'll take a look!

On Thu, 9 Jun 2022 at 22:06, Ivan Franchin @.***> wrote:

Hi, I was facing the same problem.

Btw, I've this project spring-cloud-stream-kafka-multi-topics-cloudkarafka https://github.com/ivangfr/spring-cloud-stream-kafka-multi-topics-cloudkarafka where I've implemented a pair producer / consumer using spring-kafka and another pair using spring-cloud-stream. Both can be used connecting to a CloudKarafka account or connecting to a Kafka-Zookeeper running locally in your machine.

Today, I've tried to upgrade my project, and I've faced with this ClusterAuthorizationException issue that only happens with the spring-kafka producer. Meanwhile, the spring-kafka consumer and the another pair spring-cloud-stream producer / consumer using are working fine.

Researching around, I've found this https://github.com/spring-projects/spring-boot/wiki/Spring-Boot-2.6-Release-Notes#kafka-30

In short, if you are using spring-kafka and your spring-boot version is

= 2.6, in order to solve ClusterAuthorizationException issue, just set the following in your application.properties

spring.kafka.producer.properties.enable.idempotence=false

— Reply to this email directly, view it on GitHub https://github.com/CloudKarafka/springboot-kafka-example/issues/5#issuecomment-1151568606, or unsubscribe https://github.com/notifications/unsubscribe-auth/AUM5LPWF5WRIO475CXGAGYDVOJFFTANCNFSM5U2BUAOA . You are receiving this because you commented.Message ID: @.***>

[YyuriD]

Thank you very much!!!!!! I spent half a day on this...