6.2.3. トピックおよびパーティションへのメッセージの作成

手順

1. テキストエディターを使用して、3 つのパーティションがある Kafka トピックの YAML 定義を作成します。

   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaTopic
   metadata:
     name: bridge-quickstart-topic
     labels:
       strimzi.io/cluster: <kafka-cluster-name> 1
   spec:
     partitions: 3 2
     replicas: 1
     config:
       retention.ms: 7200000
       segment.bytes: 1073741824

   1

   Kafka Bridge がデプロイされる Kafka クラスターの名前。

   2

   トピックのパーティション数。

2. ファイルを bridge-quickstart-topic.yaml として examples/topic ディレクトリーに保存します。

3. OpenShift クラスターにトピックを作成します。

   oc apply -f examples/topic/bridge-quickstart-topic.yaml

4. Kafka Bridge を使用して、作成したトピックに 3 つのメッセージを生成します。

   curl -X POST \
     http://localhost:8080/topics/bridge-quickstart-topic \
     -H 'content-type: application/vnd.kafka.json.v2+json' \
     -d '{
       "records": [
           {
               "key": "my-key",
               "value": "sales-lead-0001"
           },
           {
               "value": "sales-lead-0002",
               "partition": 2
           },
           {
               "value": "sales-lead-0003"
           }
       ]
   }'

   • sales-lead-0001 は、キーのハッシュに基づいてパーティションに送信されます。
   • sales-lead-0002 は、パーティション 2 に直接送信されます。
   • sales-lead-0003 は、ラウンドロビン方式を使用して bridge-quickstart-topic トピックのパーティションに送信されます。

5. リクエストが正常に行われると、Kafka Bridge は offsets アレイを 200 コードと application/vnd.kafka.v2+json の content-type ヘッダーとともに返します。各メッセージで、offsets アレイは以下を記述します。

   • メッセージが送信されたパーティション。

   • パーティションの現在のメッセージオフセット。

     応答の例

     #...
     {
       "offsets":[
         {
           "partition":0,
           "offset":0
         },
         {
           "partition":2,
           "offset":0
         },
         {
           "partition":0,
           "offset":1
         }
       ]
     }