2.8. 配置 pod 调度

流程

1. 编辑指定集群部署的资源中的 affinity 属性。要确保 Kafka 代理或 ZooKeeper 节点没有共享 worker 节点，请使用 strimzi.io/name 标签。将 topologyKey 设置为 kubernetes.io/hostname，以指定所选 pod 没有调度到具有相同主机名的节点。这仍然允许单个 Kafka 代理和单个 ZooKeeper 节点共享相同的 worker 节点。例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       template:
         pod:
           affinity:
             podAntiAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 - labelSelector:
                     matchExpressions:
                       - key: strimzi.io/name
                         operator: In
                         values:
                           - CLUSTER-NAME-kafka
                   topologyKey: "kubernetes.io/hostname"
       # ...
     zookeeper:
       # ...
       template:
         pod:
           affinity:
             podAntiAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 - labelSelector:
                     matchExpressions:
                       - key: strimzi.io/name
                         operator: In
                         values:
                           - CLUSTER-NAME-zookeeper
                   topologyKey: "kubernetes.io/hostname"
       # ...

   其中 CLUSTER-NAME 是 Kafka 自定义资源的名称。

2. 如果您甚至要确保 Kafka 代理和 ZooKeeper 节点没有共享相同的 worker 节点，请使用 strimzi.io/cluster 标签。例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       template:
         pod:
           affinity:
             podAntiAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 - labelSelector:
                     matchExpressions:
                       - key: strimzi.io/cluster
                         operator: In
                         values:
                           - CLUSTER-NAME
                   topologyKey: "kubernetes.io/hostname"
       # ...
     zookeeper:
       # ...
       template:
         pod:
           affinity:
             podAntiAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 - labelSelector:
                     matchExpressions:
                       - key: strimzi.io/cluster
                         operator: In
                         values:
                           - CLUSTER-NAME
                   topologyKey: "kubernetes.io/hostname"
       # ...

   其中 CLUSTER-NAME 是 Kafka 自定义资源的名称。

3. 创建或更新资源。

   oc apply -f <kafka_configuration_file>

流程

1. 编辑指定集群部署的资源中的 affinity 属性。使用标签指定不应调度到同一节点上的 pod。topologyKey 应设置为 kubernetes.io/hostname，以指定不应将所选 pod 调度到具有相同主机名的节点。例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       template:
         pod:
           affinity:
             podAntiAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 - labelSelector:
                     matchExpressions:
                       - key: application
                         operator: In
                         values:
                           - postgresql
                           - mongodb
                   topologyKey: "kubernetes.io/hostname"
       # ...
     zookeeper:
       # ...

2. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>

流程

1. 标记应调度 AMQ Streams 组件的节点。

   这可以通过 oc label:

   oc label node NAME-OF-NODE node-type=fast-network

   或者，可能会重复使用一些现有标签。

2. 编辑指定集群部署的资源中的 affinity 属性。例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       template:
         pod:
           affinity:
             nodeAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 nodeSelectorTerms:
                   - matchExpressions:
                     - key: node-type
                       operator: In
                       values:
                       - fast-network
       # ...
     zookeeper:
       # ...

3. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>

流程

1. 选择应用作专用节点。
2. 确保这些节点上没有调度任何工作负载。

3. 在所选节点上设置污点：

   这可以通过 oc adm taint 来实现：

   oc adm taint node NAME-OF-NODE dedicated=Kafka:NoSchedule

4. 另外，为所选节点添加标签。

   这可以通过 oc label:

   oc label node NAME-OF-NODE dedicated=Kafka

5. 编辑指定集群部署的资源中的 关联性 和容限 属性。

   例如：

   apiVersion: kafka.strimzi.io/v1beta2
   kind: Kafka
   spec:
     kafka:
       # ...
       template:
         pod:
           tolerations:
             - key: "dedicated"
               operator: "Equal"
               value: "Kafka"
               effect: "NoSchedule"
           affinity:
             nodeAffinity:
               requiredDuringSchedulingIgnoredDuringExecution:
                 nodeSelectorTerms:
                 - matchExpressions:
                   - key: dedicated
                     operator: In
                     values:
                     - Kafka
       # ...
     zookeeper:
       # ...

6. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>