2.4. 创建集群

流程

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