Как я могу добавить аутентификацию SASL в моем приложении Spring

Question

У меня есть одно приложение Spring, которое использует экземпляр Kafka без какой-либо аутентификации.

Теперь история меняется, Кафка вышел из Приложения и работает как Кластер.Я получил имя пользователя и пароль Kafka Credential вместе с именем хоста: информация о порте.

Какая другая информация требуется для подключения к кластеру Kafka.

Требуется ли изменение кода?Или мне просто нужно добавить информацию в файл application-profile.yaml?

Я пробовал разные подходы, предложенные в Google, но, похоже, у меня ничего не работает, я получаю:

Ошибка:
Открытие сокет-соединения с сервером X1.X2.X3.Х4 / X1.X2.X3.X4: 2181.Не будет пытаться аутентифицироваться с использованием SASL (неизвестная ошибка)

hequeue:
    #To use local kafka, update use-mock-queue to false and add local  zkservers and metadata-broker-list
    use-mock-queue: false
    zkservers: X1.X2.X3.X4:2181,Y1.Y2.Y3.Y4:2181,Z1:Z2:Z3:Z4:2181
    metadata-broker-list: X1.X2.X3.X4:9092,Y1.Y2.Y3.Y:9092,Z1:Z2:Z3:Z4:9092
    properties:
        sasl:
            jaas:
                config: org.apache.kafka.common.security.scram.ScramLoginModule required username='ANKIT' password='KOTAK';
            mechanism: SCRAM-SHA-256
            kerberos:
                service:
                    name: kafka
        security:
            protocol: SASL_SSL

Answer 1

Ниже приведен пример конфигурации пружинной кафки, которую мы используем.Если он совпадает, вы можете попробовать:

spring:
  kafka:
    bootstrap-servers: 
    consumer:
      properties:
        isolation.level: 
        ssl.truststore.location: 
        ssl.truststore.password: 
        security.protocol: SASL_SSL
        sasl.mechanism: GSSAPI
        sasl.kerberos.service.name:     
    producer: 
      properties: 
        ssl.truststore.location: 
        ssl.truststore.password: 
        security.protocol: SASL_SSL
        sasl.mechanism: GSSAPI
        sasl.kerberos.service.name: 
    admin:
      properties: 
        ssl.truststore.location: 
        ssl.truststore.password: 
        security.protocol: SASL_SSL
        sasl.mechanism: GSSAPI
        sasl.kerberos.service.name: kafka