8.3. （预览）配置节点池

流程

1. 使用 ID 为节点池添加在扩展或缩减时要使用的 ID，如下例所示。

   用于向上扩展的 ID 会被分配给节点 池池 ：

   为扩展分配 ID

   oc annotate kafkanodepool pool-a strimzi.io/next-node-ids="[0,1,2,10-20,30]"

   将节点添加到 池 时使用此范围内的最低可用 ID。

   用于缩减的 ID 分配给节点池 pool-b ：

   为缩减分配 ID

   oc annotate kafkanodepool pool-b strimzi.io/remove-node-ids="[60-50,9,8,7]"

   缩减 pool-b 时会删除此范围内的最高可用 ID。

2. 现在，您可以扩展节点池。

   如需更多信息，请参阅以下：

   • 第 8.3.2 节 “（预览）将节点添加到节点池中”
   • 第 8.3.3 节 “（预览）从节点池中删除节点”
   • 第 8.3.4 节 “（预览）在节点池之间移动节点”

   在协调时，如果注解被错误格式化，则会提供一个警告。

流程

1. 在节点池中创建新节点。

   例如，节点池 pool-a 有三个副本。我们通过增加副本数量来添加节点：

   oc scale kafkanodepool pool-a --replicas=4

2. 检查部署的状态，并等待节点池中的 pod 创建，并且状态为 READY。

   oc get pods -n <my_cluster_operator_namespace>

   输出显示节点池中的四个 Kafka 节点

   NAME                       READY  STATUS   RESTARTS
   my-cluster-pool-a-kafka-0  1/1    Running  0
   my-cluster-pool-a-kafka-1  1/1    Running  0
   my-cluster-pool-a-kafka-2  1/1    Running  0
   my-cluster-pool-a-kafka-3  1/1    Running  0

3. 在增加节点池中的节点数后重新分配分区。

   在扩展节点池后，您可以使用 Cruise Control add-brokers 模式将分区副本从现有代理移到新添加的代理中。

流程

1. 在减少节点池中的节点数前重新分配分区。

   在缩减节点池前，您可以使用 Cruise Control remove-brokers 模式将分区副本移出要删除的代理。

2. 在重新分配过程完成后，删除的节点没有实时分区，从而减少节点池中的 Kafka 节点数量。

   例如，节点池 pool-a 有四个副本。我们通过减少副本数来删除节点：

   oc scale kafkanodepool pool-a --replicas=3

   输出显示节点池中的三个 Kafka 节点

   NAME                        READY   STATUS    RESTARTS
   my-cluster-pool-b-kafka-0   1/1     Running   0
   my-cluster-pool-b-kafka-1   1/1     Running   0
   my-cluster-pool-b-kafka-2   1/1     Running   0

流程

1. 在目标节点池中创建新节点。

   例如，节点池 pool-a 有三个副本。我们通过增加副本数量来添加节点：

   oc scale kafkanodepool pool-a --replicas=4

2. 检查部署的状态，并等待节点池中的 pod 创建，并且状态为 READY。

   oc get pods -n <my_cluster_operator_namespace>

   输出显示目标节点池中的四个 Kafka 节点

   NAME                       READY  STATUS   RESTARTS
   my-cluster-pool-a-kafka-0  1/1    Running  0
   my-cluster-pool-a-kafka-1  1/1    Running  0
   my-cluster-pool-a-kafka-4  1/1    Running  0
   my-cluster-pool-a-kafka-5  1/1    Running  0

   节点 ID 在创建时附加到节点的名称中。我们添加节点 my-cluster-pool-a-kafka-5，其节点 ID 为 5。

3. 将分区从旧节点重新分配给新节点。

   在缩减源节点池前，您可以使用 Cruise Control remove-brokers 模式将分区副本移出要删除的代理。

4. 重新分配过程完成后，减少源节点池中的 Kafka 节点数量。

   例如，节点池 pool-b 具有四个副本。我们通过减少副本数来删除节点：

   oc scale kafkanodepool pool-b --replicas=3

   池中具有最高 ID 的节点已被删除。

   输出显示源节点池中的三个 Kafka 节点

   NAME                       READY  STATUS   RESTARTS
   my-cluster-pool-b-kafka-2  1/1    Running  0
   my-cluster-pool-b-kafka-3  1/1    Running  0
   my-cluster-pool-b-kafka-6  1/1    Running  0

流程

1. 创建新的 KafkaNodePool 资源。

   1. 将资源命名为 kafka。
   2. 将 strimzi.io/cluster 标签指向现有的 Kafka 资源。
   3. 设置副本数和存储配置以匹配您当前的 Kafka 集群。
   4. 将角色设置为 代理。

   迁移 Kafka 集群的节点池配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaNodePool
   metadata:
     name: kafka
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     replicas: 3
     roles:
       - broker
     storage:
       type: jbod
       volumes:
         - id: 0
           type: persistent-claim
           size: 100Gi
           deleteClaim: false

2. 应用 KafkaNodePool 资源：

   oc apply -f <node_pool_configuration_file>

   通过应用此资源，您可以将 Kafka 切换到使用节点池。

   没有更改或滚动更新和资源与之前的资源相同。

3. 更新 Cluster Operator 配置中的 STRIMZI_FEATURE_GATES 环境变量，使其包含 +KafkaNodePools。

   env:
     - name: STRIMZI_FEATURE_GATES
       value: +KafkaNodePools

4. 使用 strimzi.io/node-pools: enabled 注解，在 Kafka 资源中启用 KafkaNodePools 功能门。

   使用 ZooKeeper 在集群中节点池的配置示例

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   metadata:
     name: my-cluster
     annotations:
       strimzi.io/node-pools: enabled
   spec:
     kafka:
       version: 3.5.0
       replicas: 3
     # ...
     storage:
         type: jbod
         volumes:
         - id: 0
           type: persistent-claim
           size: 100Gi
           deleteClaim: false

5. 应用 Kafka 资源：

   oc apply -f <kafka_configuration_file>