2.6. 从 Kafka Bridge consumer 检索最新的信息

流程

1. 为 Kafka Bridge consumer 生成额外消息，如 Produc ing 消息到主题和分区 中所述。

2. 向 记录 端点提交 GET 请求：

   curl -X GET http://localhost:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer/records \
     -H 'accept: application/vnd.kafka.json.v2+json'

   Copy to Clipboard Toggle word wrap

   创建并订阅 Kafka Bridge 消费者后，第一个 GET 请求将返回空响应，因为轮询操作会启动一个重新平衡过程来分配分区。

3. 重复步骤 2，以从 Kafka Bridge 使用者检索信息。

   Kafka Bridge 返回一条信息 数组，它带有 200 代码，它包括主题名称、键、值、分区、分区以及 200 代码。默认情况下，消息从最新的偏移中检索。

   HTTP/1.1 200 OK
   content-type: application/vnd.kafka.json.v2+json
   #...
   [
     {
       "topic":"bridge-quickstart-topic",
       "key":"my-key",
       "value":"sales-lead-0001",
       "partition":0,
       "offset":0
     },
     {
       "topic":"bridge-quickstart-topic",
       "key":null,
       "value":"sales-lead-0003",
       "partition":0,
       "offset":1
     },
   #...

   Copy to Clipboard Toggle word wrap
   注意

   如果返回空响应，请生成更多记录到消费者，如 Produc ing 消息到主题和分区 中所述，然后尝试再次检索消息。