27.3. Apache Kafka DrainCleaner용 스트림 사용

프로세스

1. Kafka 브로커를 호스팅하는 지정된 OpenShift 노드를 드레이닝합니다.

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

2. Apache Kafka Drain cleaner 로그의 Streams에서 제거 이벤트를 확인하여 Pod에 다시 시작 주석이 추가되었는지 확인합니다.

   Apache Kafka Drain cleaner 로그 스트림에서 Pod의 주석 표시

   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-kafka-0
   INFO  AbstractOperator:500 - Reconciliation #13(timer) Kafka(my-project/my-cluster): reconciled