2.4. 创建 Kafka Bridge 使用者

流程

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

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

   Copy to Clipboard Toggle word wrap
   • 消费者名为 bridge-quickstart-consumer，嵌入式数据格式被设置为 json。
   • 定义了一些基本配置设置。

   • 消费者不会自动向日志提交偏移，因为 enable.auto.commit 设置为 false。稍后您将在此快速入门中手动提交偏移量。

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

     响应示例

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

     Copy to Clipboard Toggle word wrap

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