如何通过单次API调用获取Topic所有分区的偏移量?
获取指定Topic所有分区偏移量的单次API调用方法
有的,你可以通过以下单次API调用获取目标Topic所有分区的偏移量:
GET /topics/(string:topic_name)/partitions
这个接口无需指定partition_id,调用后会返回该Topic下所有分区的完整信息,其中每个分区条目都会包含对应的偏移量数据(通常包含最新偏移量、最早偏移量等)。
如果你的Kafka REST API实现支持更直接的批量偏移量查询,也可以尝试以下接口(部分自定义或扩展的REST API会提供):
GET /topics/(string:topic_name)/offsets
内容的提问来源于stack exchange,提问作者Aishwarya Sharma
相关产品推荐
相关产品推荐

