ошибка соединения с весенним облаком kafka stream

Question

Я пытаюсь подключить потоки kafka на одном из типов аутентификации хост-провайдеров kafka, это SASL_SSL, ниже - мое приложение.

Answer 1

Я решил вышеуказанную проблему, используя приведенную ниже конфигурацию @ gary-russell, пожалуйста, подтвердите, если она подходит

    spring:
        cloud.stream:
           bindings:
    greetings-in:
      destination: ms-dev-logs
      contentType: application/json
      binder: kafka1
    greetings-out:
      destination: ms-dev-logs
      contentType: application/json
      binder: kafka1
  binders:
    kafka1: 
    type: kafka
    environment:
        spring:
          cloud:
            stream:
              kafka:
                binder.brokers: ipaddr:9092,ipaddr9092,ipaddr:9092
                streams :
                  binder :
                    configuration :
                      default.key.serde: org.apache.kafka.common.serialization.Serdes$StringSerde
                      default.value.serde: org.springframework.kafka.support.serializer.JsonSerde

  kafka.binder:
    configuration:
      security.protocol: SASL_PLAINTEXT
      sasl.mechanism: SCRAM-SHA-256
kafka:
  properties:
    sasl:
      jaas:
        config : org.apache.kafka.common.security.scram.ScramLoginModule required username="usr" password="pws";

Answer 2

Я обнаружил, что проблема связана с библиотекой Spring Cloud Kafka, и команда Spring Cloud исправит ее в следующем выпуске, подробности можно найти по адресу

https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/460

Answer 3

...jaas.loginModule требуется прописная буква M

Попробуйте

    binder:
      jaas:
        loginModule : org.apache.kafka.common.security.scram.ScramLoginModule
        options:
          username: un
          password: pwd