3.3. ingress を使用した Kafka へのアクセス

手順

1. 外部リスナーを ingress タイプに設定して Kafka リソースを設定します。

   ブートストラップサービスおよび Kafka ブローカーの Ingress ホストを指定します。

   以下に例を示します。

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       listeners:
         - name: external
           port: 9094
           type: ingress
           tls: true
           authentication:
             type: tls
           configuration: 1
             bootstrap:
               host: bootstrap.myingress.com
             brokers:
             - broker: 0
               host: broker-0.myingress.com
             - broker: 1
               host: broker-1.myingress.com
             - broker: 2
               host: broker-2.myingress.com
       # ...
     zookeeper:
       # ...

   1

   ブートストラップサービスおよび Kafka ブローカーの Ingress ホスト。

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

   oc apply -f KAFKA-CONFIG-FILE

   Kafka ブローカーごとに ClusterIP タイプのサービスが作成され、さらに bootstrap service も追加されています。これらのサービスは、トラフィックを Kafka ブローカーにルーティングするために Ingress コントローラーによって使用されます。また、Ingressコントローラを使ってサービスを公開するために、各サービスに Ingress リソースを作成します。Ingress ホストは各サービスの status に伝播されます。

   kafka ブローカーの ID を検証するためのクラスター CA 証明書も、Kafka リソースと同じ名前で作成されます。

   Kafka クラスターに接続するためのブートストラップアドレスとして、configuration で指定したブートストラップホストのアドレスと、Kafka クライアントのポート 443 （BOOTSTRAP-HOST:443）を使用します。

3. ブローカーの認証局の公開証明書を取得します。

   oc get secret KAFKA-CLUSTER-NAME-cluster-ca-cert -o jsonpath='{.data.ca\.crt}' | base64 -d > ca.crt

   Kafka クライアントで取得した証明書を使用して TLS 接続を設定します。認証が有効になっている場合は、SASL または TLS 認証を設定する必要もあります。