第 4 章 创建 OpenShift 路由以访问 Kafka 集群

流程

1. 在 web 控制台中导航到 Operators > Installed Operators 页面，选择 Red Hat Integration - AMQ Streams 以显示 Operator 详情。
2. 选择 Kafka 页面来显示已安装的 Kafka 集群。

3. 点您要配置的 Kafka 集群的名称来查看其详情。

   本例中使用名为 my-cluster 的 Kafka 集群。

4. 选择 Kafka 集群 my-cluster 的 YAML 页面。

5. 添加路由监听程序配置，以创建名为 listener1 的 OpenShift 路由。

   侦听器配置必须设置为 路由 类型。您可以在 Kafka 配置中 的监听程序中添加监听程序 配置。

   外部路由监听程序配置

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
     namespace: amq-streams-kafka
   spec:
     kafka:
       # ...
       listeners:
         # ...
         - name: listener1
           port: 9094
           type: route
           tls: true
   # ...

   客户端在端口 443（默认路由器端口）上连接，但流量会路由到您配置的端口，本例中为 9094。

6. 保存更新的配置。

7. 选择 Kafka 集群 my-cluster 的 Resources 页面，以查找您需要的连接信息。

   在 Resources 页面中，您可以查找路由监听程序和需要连接到 Kafka 集群的公共集群证书的详情。

8. 点为 Kafka 集群创建的 my-cluster-kafka-listener1-bootstrap 路由的名称，以显示路由详情。

9. 记录主机名。

   主机名在 Kafka 客户端中使用端口 443 指定，作为连接到 Kafka 集群的 bootstrap 地址。

   您还可以通过导航到 Networking > Routes 并选择 amq-streams-kafka 项目来定位 bootstrap 地址，以显示命名空间中创建的路由。

   或者，您可以使用 oc 工具提取 bootstrap 详情。

   提取 bootstrap 信息

   oc get routes my-cluster-kafka-listener1-bootstrap -o=jsonpath='{.status.ingress[0].host}{"\n"}'

10. 返回到 Resources 页面，点 my-cluster-cluster-ca-cert 的名称，以显示访问 Kafka 集群的 secret 详情。

    ca.crt 证书文件包含 Kafka 集群的公共证书。

    您需要证书来访问 Kafka 代理。

11. 生成 ca.crt 公共证书文件的本地副本。

    您可以复制证书的详细信息，或者使用 OpenShift oc 工具提取它们。

    提取公共证书

    oc extract secret/my-cluster-cluster-ca-cert --keys=ca.crt --to=- > ca.crt

12. 使用 密钥 tool 为公共集群证书创建本地信任存储。

    创建本地信任存储

    keytool -keystore client.truststore.jks -alias CARoot -import -file ca.crt

    在提示时，创建用于访问 truststore 的密码。

    信任存储在 Kafka 客户端中指定，用于向 Kafka 集群验证访问权限。

    您现在已准备好开始发送和接收信息。