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

   Copy to Clipboard Toggle word wrap

   ヒント

   トピックを変更する場合、oc get kafkatopic my-topic-1 -o yaml を使用してリソースの現在のバージョンを取得できます。

2. OpenShift で KafkaTopic リソースを作成します。

   oc apply -f <topic_config_file>

   Copy to Clipboard Toggle word wrap

3. トピックの準備完了ステータスが True に変わるまで待ちます。

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

   Copy to Clipboard Toggle word wrap

   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

   Copy to Clipboard Toggle word wrap

   READY 出力が True を示す場合、トピックの作成は成功です。

4. READY 列が空白のままの場合は、リソース YAML または Topic Operator ログからステータスの詳細を取得してください。

   ステータスメッセージには、現在のステータスの理由の詳細が示されます。

   oc get kafkatopics my-topic-2 -o yaml

   Copy to Clipboard Toggle word wrap

   NotReady ステータスのトピックの詳細

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

   Copy to Clipboard Toggle word wrap

   この例では、トピックの準備ができていない理由は、KafkaTopic 設定で元のパーティション数が減ったためです。Kafka はこれをサポートしていません。

   トピック設定をリセットした後、ステータスはトピックの準備ができていることを示します。

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

   Copy to Clipboard Toggle word wrap

   トピックのステータス更新

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

   Copy to Clipboard Toggle word wrap

   詳細のフェッチではメッセージが表示されない

   oc get kafkatopics my-topic-2 -o yaml

   Copy to Clipboard Toggle word wrap

   READY ステータスのトピックの詳細

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

   Copy to Clipboard Toggle word wrap