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

手順

1. kafka-topics.sh ユーティリティーを使用してトピックを作成します。

   bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic bridge-quickstart-topic --partitions 3 --replication-factor 1 --config retention.ms=7200000 --config segment.bytes=1073741824

   3 つのパーティションを指定します。

2. トピックが作成されたことを確認します。

   bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic bridge-quickstart-topic

3. 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 トピックのパーティションに送信されます。

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

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

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

     応答の例

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