我试图通过Spring集成模块与SASL配置连接到kafka服务器并获取错误
java.lang.IllegalArgumentException：在JAAS配置中找不到“KafkaClient”条目 . 未设置系统属性“java.security.auth.login.config”
但是当我构建简单的消费者和民意调查消息时，一切正常 . 有人可以告诉我如何关闭JAAS授权或通过它正确连接 . 这是我的KafkaConfig.java和SaslConfiguration.java . 谢谢你的回答！
1 回答
有一个
KafkaConsumerFactory，它可以接受你在gist中提到的同一组属性：https://docs.spring.io/spring-kafka/docs/2.1.10.RELEASE/reference/html/_reference.html#_receiving_messages