2.8. 寻找分区偏移
使用 位置 端点配置 Kafka Bridge 使用者,以从特定偏移中检索分区的信息,然后从最新的偏移中检索。这在 Apache Kafka 中被称为 seek 操作。
流程
对于
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代码。将
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 从您想到的偏移返回信息。
通过向同一分区的最后偏移恢复默认消息检索行为。此时,使用 位置/端点。
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代码。
注意
您还可以使用 位置/关闭 端点查找一个或多个分区的第一个偏移量。
接下来要做什么
在这个快速入门中,已使用 AMQ Streams Kafka Bridge 在 Kafka 集群上执行几个通用操作。现在 ,您可以删除之前创建的 Kafka Bridge 使用者。