20.2. 스케일 다운 작업에서 검사 건너뛰기

기본적으로 Apache Kafka용 Streams는 Kafka 클러스터에서 스케일링 다운 작업을 시작하기 전에 브로커에 파티션 복제본이 없는지 확인하기 위해 검사를 수행합니다. 점검은 브로커의 역할 또는 브로커 및 컨트롤러의 이중 역할을 수행하는 노드 풀의 노드에 적용됩니다.

복제본이 발견되면 잠재적인 데이터 손실을 방지하기 위해 스케일 다운이 수행되지 않습니다. 클러스터를 확장하려면 다시 축소하기 전에 브로커에 복제본을 남겨 두지 않아야 합니다.

그러나 이 메커니즘을 우회하려는 시나리오가 있을 수 있습니다. 예를 들어 새 주제가 브로커의 복제본을 계속 생성하기 때문에 사용 중인 클러스터에 검사를 비활성화해야 할 수 있습니다. 이 상황은 브로커가 거의 비어 있어도 축소를 무기한 차단할 수 있습니다. 이러한 방식으로 차단 메커니즘을 재정의하면 영향을 받습니다. 브로커에 축소되는 항목이 있으면 Kafka 클러스터에 대한 조정 실패가 발생할 수 있습니다.

Kafka 클러스터의 Kafka 리소스에 주석을 달아 차단 메커니즘을 바이패스할 수 있습니다. strimzi.io/skip-broker-scaledown-check 주석을 true 로 설정하여 리소스에 주석을 답니다.

oc annotate Kafka my-kafka-cluster strimzi.io/skip-broker-scaledown-check="true"

이 주석은 Apache Kafka의 Streams가 스케일 다운 검사를 건너뛰도록 지시합니다. my-kafka-cluster 를 특정 Kafka 리소스의 이름으로 교체합니다.

축소 작업 검사를 복원하려면 주석을 제거합니다.

oc annotate Kafka my-kafka-cluster strimzi.io/skip-broker-scaledown-check-