流程

1. 确保您的订阅已激活，您的系统已注册。

   有关使用客户门户激活您的红帽订阅以及注册您的系统以获取软件包的更多信息，请参阅 附录 A, 使用您的订阅。

2. 从 AMQ Streams 下载网站下载 amq-streams-x.y.z-ocp-install-examples.zip 文件。

3. 将 文件解压缩到任何目标。

   • Windows 或 Mac：双击 ZIP 文件以提取 ZIP 存档的内容。
   • Red Hat Enterprise Linux：在目标计算机中打开一个终端窗口，再导航到下载 ZIP 文件的位置。

   使用以下命令提取 ZIP 文件：

   unzip amq-streams-x.y.z-ocp-install-examples.zip

流程

1. 使用具有集群管理员特权的帐户登录 OpenShift 集群。

   例如：

   oc login -u system:admin

2. 为 AMQ Streams Kafka Cluster Operator 创建一个新的 kafka （项目）命名空间。

   oc new-project kafka

3. 修改安装文件，以引用要在其中安装 AMQ Streams Kafka Cluster Operator 的新 kafka 命名空间。

   注意

   默认情况下，这些文件在 myproject 命名空间内工作。

   • 在 Linux 中，使用：

   sed -i 's/namespace: .*/namespace: kafka/' install/cluster-operator/*RoleBinding*.yaml

   • 在 Mac 中，使用：

   sed -i '' 's/namespace: .*/namespace: kafka/' install/cluster-operator/*RoleBinding*.yaml

4. 部署 CRD 和基于角色的访问控制(RBAC)资源以管理 CRD。

   oc project kafka
   oc apply -f install/cluster-operator/

5. 创建一个新的 my-kafka-project 命名空间，您要在其中部署 Kafka 集群。

   oc new-project my-kafka-project

6. 向非管理员用户 developer 授予 my-kafka-project 访问权限。

   例如：

   oc adm policy add-role-to-user admin developer -n my-kafka-project

7. 设置 STRIMZI_NAMESPACE 环境变量的值，授予 Cluster Operator 的权限以观察 my-kafka-project 命名空间。

   oc set env deploy/strimzi-cluster-operator STRIMZI_NAMESPACE=kafka,my-kafka-project -n kafka

   oc apply -f install/cluster-operator/020-RoleBinding-strimzi-cluster-operator.yaml -n my-kafka-project

   oc apply -f install/cluster-operator/032-RoleBinding-strimzi-cluster-operator-topic-operator-delegation.yaml -n my-kafka-project

   oc apply -f install/cluster-operator/031-RoleBinding-strimzi-cluster-operator-entity-operator-delegation.yaml -n my-kafka-project

   命令创建角色绑定，授予 Cluster Operator 访问 Kafka 集群的权限。

8. 创建新集群角色 strimzi-admin。

   oc apply -f install/strimzi-admin

9. 将角色添加到非管理员用户 developer。

   oc adm policy add-cluster-role-to-user strimzi-admin developer

流程

1. 以 developer 用户身份登录 my-kafka-project 命名空间。

   例如：

   oc login -u developer
   oc project my-kafka-project

   新用户登录 OpenShift 容器平台后，会为该用户创建一个帐户。

2. 创建带有 3 个 Zookeeper 和 3 代理节点的 my-cluster Kafka 集群。

   • 使用 ephemeral 存储

   • 使用配置为使用 route 的外部监听程序在 OpenShift 集群外部公开 Kafka 集群。

     cat << EOF | oc create -f -
     apiVersion: kafka.strimzi.io/v1beta2
     kind: Kafka
     metadata:
       name: my-cluster
     spec:
       kafka:
         replicas: 3
         listeners:
           - name: plain
             port: 9092
             type: internal
             tls: false
           - name: tls
             port: 9093
             type: internal
             tls: true
           - name: external
             port: 9094
             type: route 1
             tls: true
         storage:
           type: ephemeral
       zookeeper:
         replicas: 3
         storage:
           type: ephemeral
       entityOperator:
         topicOperator: {}
     EOF

3. 等待集群部署：

   oc wait my-kafka-project/my-cluster --for=condition=Ready --timeout=300s -n kafka

4. 集群就绪后，创建一个主题以从外部客户端发布和订阅。

   创建以下 my-topic 自定义资源定义，在 my-cluster Kafka 集群中使用 3 个副本和 3 个分区：

   cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaTopic
   metadata:
     name: my-topic
     labels:
       strimzi.io/cluster: "my-cluster"
   spec:
     partitions: 3
     replicas: 3
   EOF

流程

1. 查找 bootstrap 的地址 route ：

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

   在 Kafka 客户端中使用该地址和端口 443 作为 bootstrap 地址。

2. 提取代理认证机构的公共证书：

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

3. 将可信证书导入到信任存储中：

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

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

流程

1. 从 AMQ Streams 下载 网站下载最新版本的 AMQ Streams 归档( amq-streams-x.y.z-bin.zip)。

   将 文件解压缩到任何目标。

2. 打开一个终端，再启动 Kafka 控制台制作者，主题为 my-topic 以及 TLS 的身份验证属性：

   bin/kafka-console-producer.sh --broker-list ROUTE-ADDRESS:443 --producer-property security.protocol=SSL --producer-property ssl.truststore.password=password --producer-property ssl.truststore.location=./client.truststore.jks --topic my-topic

3. 在运行制作者的控制台中键入您的消息。
4. 按 Enter 发送邮件。

5. 打开一个新的终端标签页或窗口，启动 Kafka 控制台消费者以接收消息：

   bin/kafka-console-consumer.sh --bootstrap-server ROUTE-ADDRESS:443 --consumer-property security.protocol=SSL --consumer-property ssl.truststore.password=password --consumer-property ssl.truststore.location=./client.truststore.jks --topic my-topic --from-beginning

6. 确认您在使用者控制台中看到传入的消息。
7. 按 Crtl+C 退出 Kafka 控制台制作者和使用者。