9.4. 配置 Kafka 主题

流程

1. 配置 KafkaTopic 资源。

   Kafka 主题配置示例

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

   提示

   修改主题时，您可以使用 oc get kafkatopic my-topic-1 -o yaml 获取资源的当前版本。

2. 在 OpenShift 中创建 KafkaTopic 资源。

   oc apply -f <topic_config_file>

3. 等待主题的就绪状态更改为 True ：

   oc get kafkatopics -o wide -w -n <namespace>

   Kafka 主题状态

   NAME         CLUSTER     PARTITIONS  REPLICATION FACTOR READY
   my-topic-1   my-cluster  10          3                  True
   my-topic-2   my-cluster  10          3
   my-topic-3   my-cluster  10          3                  True

   当 READY 输出显示为 True 时，主题创建成功。

4. 如果 READY 列留空，请从资源 YAML 或 Topic Operator 日志中获取有关状态的更多详细信息。

   状态信息提供有关当前状态原因的详细信息。

   oc get kafkatopics my-topic-2 -o yaml

   有关具有 NotReady 状态的主题详情

   # ...
   status:
     conditions:
     - lastTransitionTime: "2022-06-13T10:14:43.351550Z"
       message: Number of partitions cannot be decreased
       reason: PartitionDecreaseException
       status: "True"
       type: NotReady

   在本例中，主题未就绪的原因是，原始分区数量在 KafkaTopic 配置中被减少。Kafka 不支持此功能。

   重置主题配置后，status 会显示主题已就绪。

   oc get kafkatopics my-topic-2 -o wide -w -n <namespace>

   主题的状态更新

   NAME         CLUSTER     PARTITIONS  REPLICATION FACTOR READY
   my-topic-2   my-cluster  10          3                  True

   获取详情不显示任何信息

   oc get kafkatopics my-topic-2 -o yaml

   有关具有 READY 状态的主题详情

   # ...
   status:
     conditions:
     - lastTransitionTime: '2022-06-13T10:15:03.761084Z'
       status: 'True'
       type: Ready