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

   Copy to Clipboard Toggle word wrap

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

   Copy to Clipboard Toggle word wrap

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

   Copy to Clipboard Toggle word wrap