12.2.7. 寻找分区的偏移
使用 位置 端点配置 Kafka 网桥使用者，以从特定偏移检索分区的消息，然后从最新的偏移中检索。这在 Apache Kafka 中称为搜索操作。
流程
为
quickstart-bridge-topic主题的分区 0 寻找特定的偏移：curl -X POST http://localhost:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer/positions \ -H 'content-type: application/vnd.kafka.v2+json' \ -d '{ "offsets": [ { "topic": "bridge-quickstart-topic", "partition": 0, "offset": 2 } ] }'如果请求成功，Kafka Bridge 只会返回
204 No Content代码。向
records端点提交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'
Kafka Bridge 从您要查找的偏移返回消息。
通过查找同一分区的最后偏移来恢复默认消息检索行为。这一次使用 position /end 端点。
curl -X POST http://localhost:8080/consumers/bridge-quickstart-consumer-group/instances/bridge-quickstart-consumer/positions/end \ -H 'content-type: application/vnd.kafka.v2+json' \ -d '{ "partitions": [ { "topic": "bridge-quickstart-topic", "partition": 0 } ] }'如果请求成功，Kafka Bridge 会返回另一个
204 No Content代码。
注意
您还可以使用 位置/探测端点 来查找一个或多个分区的第一个偏移。
接下来要做什么
在这个快速入门中，您已使用 AMQ Streams Kafka Bridge 在 Kafka 集群上执行几个常用操作。现在 ，您可以删除之前创建的 Kafka 网桥消费者。
其它资源
- API 参考文档中的 POST/consumers/{groupid}/instances/{name}/ 位置。
- POST /consumers/{groupid}/instances/{name}/locations/beginning in the API 参考文档中。
- 在 API 参考文档中 POST /consumers/{groupid}/instances/{name}/locations/end。
