Мануалы и справочники Общие команды
kafkacat

Команда kafkacat: опции, ключи и примеры использования

kafkacat

Инструменты Apache Kafka для отправки и получения сообщений.

  • Получить сообщения, начиная с новейшего отступа (оффсета):

kafkacat -C -t {{topic}} -b {{brokers}}

  • Получить сообщения, начиная со старейшего отступа и выйти после последнего полученного сообщения:

kafkacat -C -t {{topic}} -b {{brokers}} -o beginning -e

  • Получить сообщения от имени группы получателей Kafka:

kafkacat -G {{group_id}} {{topic}} -b {{brokers}}

  • Опубликовать сообщение, полученное со стандартного потока ввода (stdin):

echo {{message}} | kafkacat -P -t {{topic}} -b {{brokers}}

  • Опубликовать сообщения, полученные из файла:

kafkacat -P -t {{topic}} -b {{brokers}} {{path/to/file}}

  • Вывести мета-данные для всех топиков и брокеров:

kafkacat -L -b {{brokers}}

  • Вывести мета-данные для указанного топика:

kafkacat -L -t {{topic}} -b {{brokers}}

  • Получить отступ для топика/партиции для указанной точки во времени:

kafkacat -Q -t {{topic}}:{{partition}}:{{unix_timestamp}} -b {{brokers}}