6.3. 部署 Kafka

流程

1. 创建和部署临时或持久的集群。

   • 创建和部署临时集群：

     oc apply -f examples/kafka/kafka-ephemeral.yaml

   • 创建和部署持久集群：

     oc apply -f examples/kafka/kafka-persistent.yaml

2. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   my-cluster-kafka-0          1/1     Running   0
   my-cluster-kafka-1          1/1     Running   0
   my-cluster-kafka-2          1/1     Running   0
   my-cluster-zookeeper-0      1/1     Running   0
   my-cluster-zookeeper-1      1/1     Running   0
   my-cluster-zookeeper-2      1/1     Running   0

   my-cluster 是 Kafka 集群的名称。

   使用默认部署，您要安装一个 Entity Operator 集群、3 Kafka pod 和 3 ZooKeeper pod。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。

流程

1. 编辑 Kafka 资源的 entityOperator 属性，使其包含 topicOperator ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. 使用 EntityTopicOperatorSpec schema reference 中所述的属性配置 Topic Operator spec。

   如果您希望所有属性使用它们的默认值，请使用空对象({})。

3. 创建或更新资源：

   oc apply -f <kafka_configuration_file>

4. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster 是 Kafka 集群的名称。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。

流程

1. 编辑 Kafka 资源的 entityOperator 属性，使其包含 userOperator ：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
   spec:
     #...
     entityOperator:
       topicOperator: {}
       userOperator: {}

2. 使用 EntityUserOperatorSpec schema reference 中所述的属性配置 User Operator spec。

   如果您希望所有属性使用它们的默认值，请使用空对象({})。

3. 创建或更新资源：

   oc apply -f <kafka_configuration_file>

4. 检查部署的状态：

   oc get pods -n <my_cluster_operator_namespace>

   输出显示了 pod 名称和就绪度

   NAME                        READY   STATUS    RESTARTS
   my-cluster-entity-operator  3/3     Running   0
   # ...

   my-cluster 是 Kafka 集群的名称。

   READY 显示 ready/expected 的副本数量。当 STATUS 显示为 Running 时，部署成功。