12.2.3. 创建 Kafka 网桥消费者

流程

1. 在名为 bridge-quickstart-consumer-group 的新消费者组中创建一个 Kafka 网桥消费者：

   curl -X POST http://localhost:8080/consumers/bridge-quickstart-consumer-group \
     -H 'content-type: application/vnd.kafka.v2+json' \
     -d '{
       "name": "bridge-quickstart-consumer",
       "auto.offset.reset": "earliest",
       "format": "json",
       "enable.auto.commit": false,
       "fetch.min.bytes": 512,
       "consumer.request.timeout.ms": 30000
     }'

   • 使用者名为 bridge-quickstart-consumer，嵌入式数据格式被设置为 json。

   • 由于 enable.auto.commit 设置是 false，因此使用者不会自动向日志提交偏移。在此快速入门稍后您将手动提交偏移。

     注意

     如果您没有在请求正文中指定消费者名称，Kafka Bridge 将生成随机消费者名称。

     如果请求成功，Kafka Bridge 返回响应正文中的消费者 ID(instance_id)和基本 URL(base_uri)，以及 200 (OK)代码。

     响应示例

     #...
     {
       "instance_id": "bridge-quickstart-consumer",
       "base_uri":"http://<bridge-name>-bridge-service:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer"
     }

2. 复制基本 URL(base_uri)，以便在这个快速启动的其他消费者操作中使用。