我正试图通过带有sasl config的spring集成模块连接到kafka服务器，结果出错
java.lang.illegalargumentexception:在jaas配置中找不到“kafkaclient”条目。未设置系统属性“java.security.auth.login.config”
但是当我构造简单的消费者和投票消息时，一切都正常。有人能告诉我如何关闭jaas授权或通过它正确连接吗。这是我的kafkanconfig.java和saslconfiguration.java。谢谢你的回答！
1条答案
按热度按时间ttcibm8c1#
有一个
KafkaConsumerFactory它可以简单地接受您在gist中提到的同一组属性：https://docs.spring.io/spring-kafka/docs/2.1.10.release/reference/html/_reference.html#_receiving_messages