6.2.4. 创建 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 会在响应正文返回使用者 ID(instance_id)和基本 URL(base_uri)，以及 200 代码。

     响应示例

     #...
     {
       "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)，以便在这个快速启动的其他消费者操作中使用。