Я пытаюсь подключить приложение весенней загрузки kafka к kafka в облаке alibaba.
Облако включено Служба e-mapreduce .
Однако я не могу подключиться из загрузки, может быть из-за некоторых учетных данных, которые мне нужно предоставить?
Я уже пытался установить свойства загрузки следующим образом:
spring.kafka.properties.security.protocol=SSL
Ошибка получения: Соединение с узлом -1 (/ xx.xx.xx.xx: 9092) прекращено во время аутентификации. Это может произойти по любой из следующих причин: (1) проверка подлинности не удалась из-за неверных учетных данных у брокеров старше 1.0.0, (2) брандмауэр блокирует трафик Kafka TLS c (например, он может разрешить только трафик HTTPS c ), (3) Временная проблема сети.
spring.kafka.properties.security.protocol=SASL_SSL
Броски Причина: java .lang.IllegalArgumentException: Не удалось найти запись KafkaClient в конфигурации JAAS. Системное свойство 'java .security.auth.login.config' не установлено
У кого-нибудь есть опыт подключения к kafka в облаке alibaba?