2.9. 配置 pod 调度

流程

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

   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"
       # ...

   Copy to Clipboard Toggle word wrap

   其中 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"
       # ...

   Copy to Clipboard Toggle word wrap

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

3. 创建或更新资源。

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

流程

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:
       # ...

   Copy to Clipboard Toggle word wrap

2. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

流程

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

   这可以通过 oc label 完成：

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

   Copy to Clipboard Toggle word wrap

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

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:
       # ...

   Copy to Clipboard Toggle word wrap

3. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap

流程

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

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

   这可以通过 oc adm taint 完成：

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

   Copy to Clipboard Toggle word wrap

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

   这可以通过 oc label 完成：

   oc label node NAME-OF-NODE dedicated=Kafka

   Copy to Clipboard Toggle word wrap

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:
       # ...

   Copy to Clipboard Toggle word wrap

6. 创建或更新资源。

   这可以通过 oc apply 完成：

   oc apply -f <kafka_configuration_file>

   Copy to Clipboard Toggle word wrap