Kafka Spring интеграции авторизации с SASL - PullRequest
0 голосов
/ 27 сентября 2018

Я пытаюсь подключиться к серверу kafka через модуль весенней интеграции с конфигурацией SASL и получаю ошибку

java.lang.IllegalArgumentException: Не удалось найти запись «KafkaClient» в конфигурации JAAS.Системное свойство 'java.security.auth.login.config' не установлено

, но когда я создаю простые сообщения потребителей и опроса, все работает нормально.Может кто-нибудь подсказать, как отключить авторизацию JAAS или правильно подключиться через него.Вот мои KafkaConfig.java и SaslConfiguration.java .Спасибо за ответ!

1 Ответ

0 голосов
/ 28 сентября 2018

Существует KafkaConsumerFactory, который просто может принять тот же набор свойств, который вы упомянули в своей сущности: https://docs.spring.io/spring-kafka/docs/2.1.10.RELEASE/reference/html/_reference.html#_receiving_messages

...