java.lang.IllegalArgumentException: Could not find a ‘KafkaClient‘ entry in the JAAS configuration.
springboot+kafka
·
错误出现:
项目集成带权限认证的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>
更多推荐
已为社区贡献1条内容
所有评论(0)