如何获取 Kafka 主题分区的最后偏移量？

【问题标题】：How to get last offset of a partition of a Kafka topic?如何获取 Kafka 主题分区的最后偏移量？
【发布时间】：2019-07-04 08:10:17
【问题描述】：

我正在使用 C 库 (librdkafka) 来编写 Kafka 消费者。我需要知道给定主题的分区的最后偏移量（以及滞后）。我知道使用 Python 是可能的（来自 Stackoverflow 上的类似帖子），但我没有找到用 C 语言实现它的方法......谢谢。

【问题讨论】：

标签： c apache-kafka librdkafka

【解决方案1】：

您可以使用query_watermark_offsets 来获取分区的高偏移量和低偏移量。

query_watermark_offsets (const std::string &topic, int32_t partition, int64_t *low, int64_t *high, int timeout_ms)=0

查询代理以获取低（最旧/开始）和高（最新/结束）偏移量用于分区。

偏移量分别在 *low 和 *high 中返回。

成功时返回RdKafka::ERR_NO_ERROR，失败时返回错误代码。

【讨论】：

非常感谢：rd_kafka_query_watermark_offsets 能解决问题，高偏移量正是我所需要的！