如何在我的 Spring 应用程序中添加 SASL 身份验证答案

【问题标题】：How I can add SASL Authentication in my Spring Application如何在我的 Spring 应用程序中添加 SASL 身份验证
【发布时间】：2019-08-27 21:55:49
【问题描述】：

我有一个 Spring 应用程序，它使用没有任何身份验证的 Kafka 实例。

现在情况发生了变化，Kafka 移出了应用程序并作为集群运行。我收到了 Kafka Credential 用户名和密码以及主机名：端口信息。

我需要什么其他信息才能连接到 Kafka 集群。

是否需要更改任何代码？还是我只需要在 application-profile.yaml 文件中添加一些信息？

我尝试了谷歌建议的不同方法，但似乎对我没有用，我不断得到：

错误：
打开与服务器 X1.X2.X3.X4/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

【问题讨论】：

该警告来自 Zookeeper，而不是 Kafka

标签： java spring apache-kafka

【解决方案1】：

以下是我们如何使用 spring kafka 的示例配置之一。如果匹配，您可以尝试：

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

【讨论】：