3.4.2. 使用 DIGEST-MD5 启用服务器到服务器的身份验证

启用 SASL DIGEST-MD5 身份验证

1. 在所有 ZooKeeper 节点上，创建或编辑 /opt/kafka/config/zookeeper-jaas.conf JAAS 配置文件并添加以下上下文：

   QuorumServer {
          org.apache.zookeeper.server.auth.DigestLoginModule required
          user_<Username>="<Password>";
   };
   
   QuorumLearner {
          org.apache.zookeeper.server.auth.DigestLoginModule required
          username="<Username>"
          password="<Password>";
   };

   在 JAAS 上下文中，用户名和密码必须相同。例如：

   QuorumServer {
          org.apache.zookeeper.server.auth.DigestLoginModule required
          user_zookeeper="123456";
   };
   
   QuorumLearner {
          org.apache.zookeeper.server.auth.DigestLoginModule required
          username="zookeeper"
          password="123456";
   };

2. 在所有 ZooKeeper 节点上，编辑 /opt/kafka/config/zookeeper.properties ZooKeeper 配置文件并设置以下选项：

   quorum.auth.enableSasl=true
   quorum.auth.learnerRequireSasl=true
   quorum.auth.serverRequireSasl=true
   quorum.auth.learner.loginContext=QuorumLearner
   quorum.auth.server.loginContext=QuorumServer
   quorum.cnxn.threads.size=20

3. 逐个重启所有 ZooKeeper 节点。要将 JAAS 配置传递给 ZooKeeper，请使用 KAFKA_OPTS 环境变量。

   su - kafka
   export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/zookeeper-jaas.conf"; /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties