springkafka集成后给kafka集群发送失败（cluster authorization failed）

1、kafka集群使用的是SASL/SCRAM-SHA-256认证sasl-mechanism: SCRAM-SHA-256security-protocol: SASL_PLAINTEXTsasl-jaas-config: org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" passw

岁月呀

2573人浏览 · 2021-09-16 21:51:03

岁月呀 · 2021-09-16 21:51:03 发布

1、kafka集群使用的是SASL/SCRAM-SHA-256认证

sasl-mechanism: SCRAM-SHA-256
security-protocol: SASL_PLAINTEXT
sasl-jaas-config: org.apache.kafka.common.security.scram.ScramLoginModule required username="admin" password="Wisebrain@20210621";

解决方案：
https://stackoverflow.com/questions/67148019/kafka-producer-property-enable-idempotence-true-is-causing-error

搜了一下发现是kafka生产者的幂等性配置导致的
将幂等性配置改为false