23.3. 使用 Apache Kafka Drain Cleaner 的 Streams

流程

1. 排空托管 Kafka 代理或 ZooKeeper pod 的指定 OpenShift 节点。

   oc get nodes
   oc drain <name-of-node> --delete-emptydir-data --ignore-daemonsets --timeout=6000s --force

2. 检查流中的 Apache Kafka Drain Cleaner 日志中的驱除事件，以验证 pod 是否已注解用于重启。

   Apache Kafka Drain Cleaner 日志的流显示 pod 的注解

   INFO ... Received eviction webhook for Pod my-cluster-zookeeper-2 in namespace my-project
   INFO ... Pod my-cluster-zookeeper-2 in namespace my-project will be annotated for restart
   INFO ... Pod my-cluster-zookeeper-2 in namespace my-project found and annotated for restart
   
   INFO ... Received eviction webhook for Pod my-cluster-kafka-0 in namespace my-project
   INFO ... Pod my-cluster-kafka-0 in namespace my-project will be annotated for restart
   INFO ... Pod my-cluster-kafka-0 in namespace my-project found and annotated for restart

3. 检查 Cluster Operator 日志中的协调事件，以验证滚动更新。

   Cluster Operator 日志显示滚动更新

   INFO  PodOperator:68 - Reconciliation #13(timer) Kafka(my-project/my-cluster): Rolling Pod my-cluster-zookeeper-2
   INFO  PodOperator:68 - Reconciliation #13(timer) Kafka(my-project/my-cluster): Rolling Pod my-cluster-kafka-0
   INFO  AbstractOperator:500 - Reconciliation #13(timer) Kafka(my-project/my-cluster): reconciled