2.5. 创建 Kafka Bridge consumer

流程

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

   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_id>-bridge-service:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer"
     }

2. 复制用于此快速入门的其他消费者操作的基本 URL(base_uri)。