15.3. Kafka ブローカーへのアクセスのセキュア化

手順

1. Kafka リソースを設定します。

   1. 承認には authorization プロパティーを設定します。

   2. listeners プロパティーを設定し、認証でリスナーを作成します。

      以下に例を示します。

      apiVersion: kafka.strimzi.io/v1beta2
      kind: Kafka
      spec:
        kafka:
          # ...
          authorization: 

      1

      
            type: simple
            superUsers: 

      2

      
              - CN=client_1
              - user_2
              - CN=client_3
          listeners:
            - name: tls
              port: 9093
              type: internal
              tls: true
              authentication:
                type: tls 

      3

      
          # ...
        zookeeper:
          # ...

      Copy to Clipboard Toggle word wrap

      1

      認可により、AclAuthorizer および StandardAuthorizer Kafka プラグインを使用した Kafka ブローカーでの simple 認可が可能になります。

      2

      Kafka へのアクセスを制限されないユーザープリンシパルのリスト。CN は、mTLS による認証が使用される場合のクライアント証明書のコモンネームです。

      3

      リスナーの認証メカニズムは各リスナーに対して設定でき、mTLS、SCRAM-SHA-512、またはトークンベース OAuth 2.0 として指定 できます。

      外部リスナーを設定している場合、設定は選択した接続のメカニズムによって異なります。

2. Kafka リソースを作成または更新します。

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

   Kafka クラスターは、mTLS 認証を使用する Kafka ブローカーリスナーと共に設定されます。

   Kafka ブローカー Pod ごとにサービスが作成されます。

   サービスが作成され、Kafka クラスターに接続するための ブートストラップアドレス として機能します。

   kafka ブローカーのアイデンティティーを検証するクラスター CA 証明書もシークレット <cluster_name>-cluster-ca-cert に作成されます。

手順

1. KafkaUser リソースを設定します。

   以下に例を示します。

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaUser
   metadata:
     name: my-user
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     authentication: 

   1

   
       type: tls
     authorization:
       type: simple 

   2

   
       acls:
         - resource:
             type: topic
             name: my-topic
             patternType: literal
           operations:
             - Describe
             - Read
         - resource:
             type: group
             name: my-group
             patternType: literal
           operations:
             - Read

   Copy to Clipboard Toggle word wrap

   1

   相互 tls または scram-sha-512 として定義されたユーザー認証メカニズム。

   2

   ACL ルールのリストが必要な簡易承認。

2. KafkaUser リソースを作成または更新します。

   oc apply -f <user_config_file>

   Copy to Clipboard Toggle word wrap

   KafkaUser リソースと同じ名前の Secret と共に、ユーザーが作成されます。Secret には、mTLS 認証用の秘密鍵と公開鍵が含まれています。

手順

1. Kafka リソースを開きます。

2. networkPolicyPeers プロパティーで、Kafka クラスターへのアクセスが許可されるアプリケーション Pod または namespace を定義します。

   以下は、ラベル app が kafka-client に設定されているアプリケーションからの接続のみを許可するよう tls リスナーを設定する例になります。

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       listeners:
         - name: tls
           port: 9093
           type: internal
           tls: true
           authentication:
             type: tls
           networkPolicyPeers:
             - podSelector:
                 matchLabels:
                   app: kafka-client
       # ...
     zookeeper:
       # ...

   Copy to Clipboard Toggle word wrap

3. リソースを作成または更新します。

   次のように oc apply を使用します。

   oc apply -f your-file

   Copy to Clipboard Toggle word wrap

手順

1. 秘密鍵およびサーバー証明書が含まれる Secret を作成します。

   oc create secret generic my-secret --from-file=my-listener-key.key --from-file=my-listener-certificate.crt

   Copy to Clipboard Toggle word wrap

2. クラスターの Kafka リソースを編集します。

   Secret、証明書ファイル、および秘密鍵ファイルを使用するように、リスナーを configuration.brokerCertChainAndKey プロパティーで設定します。

   TLS 暗号化が有効な loadbalancer 外部リスナーの設定例

   # ...
   listeners:
     - name: plain
       port: 9092
       type: internal
       tls: false
     - name: external3
       port: 9094
       type: loadbalancer
       tls: true
       configuration:
         brokerCertChainAndKey:
           secretName: my-secret
           certificate: my-listener-certificate.crt
           key: my-listener-key.key
   # ...

   Copy to Clipboard Toggle word wrap

   TLS リスナーの設定例

   # ...
   listeners:
     - name: plain
       port: 9092
       type: internal
       tls: false
     - name: tls
       port: 9093
       type: internal
       tls: true
       configuration:
         brokerCertChainAndKey:
           secretName: my-secret
           certificate: my-listener-certificate.crt
           key: my-listener-key.key
   # ...

   Copy to Clipboard Toggle word wrap

3. 新しい設定を適用してリソースを作成または更新します。

   oc apply -f kafka.yaml

   Copy to Clipboard Toggle word wrap

   Cluster Operator は、Kafka クラスターのローリング更新を開始し、これによりリスナーの設定が更新されます。

   注記

   リスナーによってすでに使用されている Secret の Kafka リスナー証明書を更新した場合でも、ローリング更新が開始されます。