6.2.3. 生成到主题和分区的消息

步骤

1. 在文本编辑器中，为带有三个分区的 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

   Copy to Clipboard Toggle word wrap

   1

   部署 Kafka Bridge 的 Kafka 集群的名称。

   2

   主题的分区数量。

2. 将文件保存到 example /topic 目录中，作为 bridge-quickstart-topic.yaml。

3. 在 OpenShift 集群中创建主题：

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

   Copy to Clipboard Toggle word wrap

4. 使用 Kafka Bridge，为您创建的主题生成三个信息：

   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"
           }
       ]
   }'

   Copy to Clipboard Toggle word wrap
   • sales-lead-0001 发送至基于密钥哈希的分区。
   • sales-lead-0002 直接发送到分区 2。
   • sales-lead-0003 通过循环方法发送到 bridge-quickstart-topic 主题中的分区。

5. 如果请求成功，Kafka Bridge 将返回一个 偏移数组，以及 200 代码 和内容类型 标头 application/vnd.kafka.v2+json。对于每条消息，偏移 阵列描述：

   • 消息发送到的分区

   • 分区的当前消息偏移

     响应示例

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

     Copy to Clipboard Toggle word wrap