Как потреблять сообщения из определенного раздела темы в kafka

Я хочу, чтобы потребитель kafka получал сообщения из определенного / указанного раздела темы

Он работает с использованием kafka-console-consumer.sh с переключателем --partition partition_number

Я использую код kafka_complex_consumer_example.c из librdkafka

После статического анализа кода я чувствую, что он может служить моей цели, но я не могу узнать точные параметры командной строки, которые нужно передать в функцию main (int argc & char ** argv) для запуска кода и начала использования конкретный раздел темы.

Взгляните на код здесь - rdkafka_complex_consumer_example.c

Полный код github для librdkafka здесь, FYR

Если этот код не служит цели, укажите другой код, который может помочь


person AjayVishwakarma_AV    schedule 10.06.2021    source источник


Ответы (1)


Если вы посмотрите на строку использования, поставив двоеточие после названия темы, вы укажете, какой раздел использовать из

В частности, тип раздела раздела содержит информацию о конкретном разделе, и эта строка создает список этих разделов.

https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_complex_consumer_example.c#L528

person OneCricketeer    schedule 10.06.2021
comment
Тема: Раздел решил мою проблему. Упомяните двоеточие (:) между ними без пробелов. Спасибо @OneCricketer - person AjayVishwakarma_AV; 14.06.2021
comment
Не стесняйтесь использовать галочку рядом с ответом, чтобы принять его - person OneCricketeer; 14.06.2021