2.8. 寻找分区偏移量
使用 位置 端点配置 Kafka Bridge 消费者,从特定偏移中检索分区的消息,然后从最新的偏移中检索。这在 Apache Kafka 中被称为 seek 操作。
流程
请参阅
quickstart-bridge-topic主题的分区 0 的特定偏移:Copy to Clipboard Copied! Toggle word wrap Toggle overflow 如果请求成功,Kafka Bridge 只会返回一个
204代码。向
记录端点提交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'
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 Copied! Toggle word wrap Toggle overflow Kafka Bridge 从您看到的偏移返回信息。
通过查找同一分区的最后一个偏移来恢复默认消息检索行为。这一次,使用 位置/结束 端点。
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 如果请求成功,Kafka Bridge 会返回另一个
204代码。
注意
您还可以使用 positions/beginning 端点查找一个或多个分区的第一个偏移。
接下来要做什么
在这个快速入门中,您使用 Kafka Bridge 在 Kafka 集群中执行几个常见操作。现在 ,您可以删除之前创建的 Kafka Bridge 使用者。