5.3. ZooKeeper の設定

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 ノードを 1 つずつ再起動します。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

SASL DIGEST-MD5 認証の有効化

1. すべての ZooKeeper ノードで、/opt/kafka/config/zookeeper-jaas.conf JAAS 設定ファイルを作成または編集し、以下のコンテキストを追加します。

   Server {
       org.apache.zookeeper.server.auth.DigestLoginModule required
       user_super="<SuperUserPassword>"
       user<Username1>_="<Password1>" user<USername2>_="<Password2>";
   };

   super は自動的に管理者特権を持たせます。このファイルには複数のユーザーを含めることができますが、Kafka ブローカーが必要とする追加ユーザーは 1 つだけです。Kafka ユーザーに推奨される名前は kafka です。

   以下の例は、クライアント/サーバー間の認証の Server コンテキストを示しています。

   Server {
       org.apache.zookeeper.server.auth.DigestLoginModule required
       user_super="123456"
       user_kafka="123456";
   };

2. すべての ZooKeeper ノードで、/opt/kafka/config/zookeeper.properties ZooKeeper 設定ファイルを編集し、以下のオプションを設定します。

   requireClientAuthScheme=sasl
   authProvider.<IdOfBroker1>=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
   authProvider.<IdOfBroker2>=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
   authProvider.<IdOfBroker3>=org.apache.zookeeper.server.auth.SASLAuthenticationProvider

   authProvider.<ID> プロパティーは、ZooKeeper クラスターの一部であるすべてのノードに追加する必要があります。3 ノードの ZooKeeper クラスターの設定例は以下のようになります。

   requireClientAuthScheme=sasl
   authProvider.1=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
   authProvider.2=org.apache.zookeeper.server.auth.SASLAuthenticationProvider
   authProvider.3=org.apache.zookeeper.server.auth.SASLAuthenticationProvider

3. すべての ZooKeeper ノードを 1 つずつ再起動します。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