第 21 章 使用 Cruise Control 修改主题复制因素

流程

1. 编辑 KafkaTopic 资源以更改 replicas 值。

   在此过程中，我们将 my-topic 的 replicas 值从 1 改为 3。

   Kafka 主题复制因素配置

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaTopic
   metadata:
     name: my-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 1
     replicas: 3
     # ...

   Copy to Clipboard Toggle word wrap

2. 将更改应用到 KafkaTopic 配置，并等待 Topic Operator 更新主题。

3. 检查 KafkaTopic 资源的状态，以确保请求成功：

   oc get kafkatopics my-topic -o yaml

   Copy to Clipboard Toggle word wrap

   复制因子更改的状态

   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaTopic
   metadata:
     name: my-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 1
     replicas: 3
     # ...
   
   # ...
   status:
     conditions:
     - lastTransitionTime: "2024-01-18T16:13:50.490918232Z"
       status: "True"
       type: Ready
     observedGeneration: 2
     replicasChange:
       sessionId: 1aa418ca-53ed-4b93-b0a4-58413c4fc0cb 

   1

   
       state: ongoing 

   2

   
       targetReplicas: 3 

   3

   
     topicName: my-topic

   Copy to Clipboard Toggle word wrap

   1

   Cruise Control 操作的会话 ID，它会在进程移出待处理状态时显示。

   2

   更新的状态。从 pending 移到 ongoing，然后在更改完成后删除整个 replicasChange 状态。

   3

   请求的副本数量会改变。

   如果请求在完成前失败，状态中会显示错误消息。如果请求进入失败状态，则会定期重试。