错误出现:

项目集成带权限认证的kafka集群,然后引入spring-kafka后,调用KafkaTemplate后出错

引入依赖:

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

yml增加配置:

####################### auth-kafka end #######################
spring.kafka.bootstrap-servers=ip1,ip2,ip3
spring.kafka.properties.sasl.mechanism=SCRAM-SHA-256
spring.kafka.properties.security.protocol=SASL_PLAINTEXT
spring.kafka.properties.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="your-userName" password="your-password";
spring.kafka.consumer.session-timeout-ms=15000
spring.kafka.consumer.enable-auto-commit=false
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.groupId=your-groupId
####################### auth-kafka end #######################

 

错误出现原因:

缺少依赖:kafka-client【kafka权限认证的类ScramLoginModule存在于kafka-client中,此处报错提示也不是很清楚=-=,细心,细心】

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>2.4.1</version>
</dependency>
Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐