使用 S Amazon ecrets Manager 进行登录凭据身份验证

使用以下命令检索集群详细信息。ClusterArn替换为集群的 Amazon 资源名称 (ARN)：

aws kafka describe-cluster --cluster-arn "ClusterArn"

从命令的 JSON 结果中，保存与名为 ZookeeperConnectString 的字符串关联的值。

要创建示例主题，在您的客户端计算机上运行以下命令。ZookeeperConnectString替换为您在上一步中录制的字符串。

<path-to-your-kafka-installation>/bin/kafka-topics.sh --create --zookeeper ZookeeperConnectString --replication-factor 3 --partitions 1 --topic ExampleTopicName

在您的客户端计算机上，创建一个 JAAS 配置文件，其中包含存储在密钥中的用户凭证。例如，对于用户 alice，使用以下内容创建一个名为 users_jaas.conf 的文件。

KafkaClient {
   org.apache.kafka.common.security.scram.ScramLoginModule required
   username="alice"
   password="alice-secret";
};

使用以下命令将 JAAS 配置文件导出为 KAFKA_OPTS 环境参数。

export KAFKA_OPTS=-Djava.security.auth.login.config=<path-to-jaas-file>/users_jaas.conf

在 ./tmp 目录中创建一个名为 kafka.client.truststore.jks 的文件。

使用以下命令将 JDK 密钥存储文件从 JVM cacerts 文件夹复制到您在上一步中创建的 kafka.client.truststore.jks 文件。将 JDKFolder 替换为实例上 JDK 文件夹的名称。例如，您的 JDK 文件夹可能命名为 java-1.8.0-openjdk-1.8.0.201.b09-0.amzn2.x86_64。

cp /usr/lib/jvm/JDKFolder/jre/lib/security/cacerts /tmp/kafka.client.truststore.jks

在 Apache Kafka 安装的 bin 目录中，创建一个名为 client_sasl.properties 的客户端属性文件，其中包含以下内容。此文件可定义 SASL 机制和协议。

security.protocol=SASL_SSL
sasl.mechanism=SCRAM-SHA-512
ssl.truststore.location=<path-to-keystore-file>/kafka.client.truststore.jks

使用以下命令检索引导代理字符串。ClusterArn替换为集群的 Amazon 资源名称 (ARN)：

aws kafka get-bootstrap-brokers --cluster-arn ClusterArn

从命令的 JSON 结果中，保存与名为 BootstrapBrokerStringSaslScram 的字符串关联的值。

要生成您创建的示例主题，请在客户端计算机上运行以下命令。BootstrapBrokerStringSaslScram替换为您在上一步中检索到的值。

<path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapBrokerStringSaslScram --topic ExampleTopicName --producer.config client_sasl.properties

要使用您创建的主题，在您的客户端计算机上运行以下命令。BootstrapBrokerStringSaslScram用您之前获得的值替换。

<path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapBrokerStringSaslScram --topic ExampleTopicName --from-beginning --consumer.config client_sasl.properties