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

Question

Я использую библиотеку C (librdkafka) написать потребителю кафку. Мне нужно знать последнее смещение раздела данной темы (и отставание тоже). Я знаю, что это возможно с Python (из аналогичного поста на Stackru), но я не нашел способ сделать это в 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

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

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

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