23.3. Using the Streams for Apache Kafka Drain Cleaner

Procedure

1. Drain a specified OpenShift node hosting the Kafka broker or ZooKeeper pods.

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

2. Check the eviction events in the Streams for Apache Kafka Drain Cleaner log to verify that the pods have been annotated for restart.

   Streams for Apache Kafka Drain Cleaner log show annotations of pods

   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. Check the reconciliation events in the Cluster Operator log to verify the rolling updates.

   Cluster Operator log shows rolling updates

   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