Как получить последнее смещение раздела темы Кафки?

Question

Я использую библиотеку C (librdkafka), чтобы написать потребителя Kafka. Мне нужно знать последнее смещение раздела данной темы (и отставание тоже). Я знаю, что это возможно с Python (из аналогичного поста в Stackoverflow), но я не нашел способа сделать это в C ... Спасибо.

Answer 1

Вы можете использовать query_watermark_offsets, чтобы получить как высокие, так и низкие смещения раздела.

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

Брокер запросов для низких (самых старых / начальных) и высоких (самых новых / конечных) смещений для раздела.

Смещения возвращаются в * низкоми * high соответственно.

Возвращает RdKafka::ERR_NO_ERROR в случае успеха или код ошибки при ошибке.