Изучение тем Kafka с помощью Kafkacat: методы и команды

«Информация о теме Kafkacat» — это команда, используемая с Kafkacat, утилитой командной строки для Apache Kafka. Он предоставляет информацию по конкретной теме Kafka. Вот несколько методов, которые вы можете использовать для получения информации о теме с помощью Kafkacat:

  1. Основная информация о теме: выполните следующую команду, чтобы получить основную информацию о теме Kafka:

    kafkacat -L -b <bootstrap_servers> -t <topic_name>

    Замените списком брокеров Kafka, разделенным запятыми, а названием темы, информацию о которой вы хотите получить.

  2. Подробная информация о теме. Чтобы получить подробную информацию о теме, включая информацию о разделах и лидерах, используйте следующую команду:

    kafkacat -b <bootstrap_servers> -t <topic_name> -p 0 -C -o -1

    Эта команда считывает последнее сообщение (смещение -1) из раздела 0 (-p 0) указанной темы.

  3. Вывести список всех тем. Если вы хотите вывести список всех тем, доступных в кластере Kafka, вы можете использовать следующую команду:

    kafkacat -L -b <bootstrap_servers>
  4. Получить конфигурацию темы. Чтобы получить сведения о конфигурации конкретной темы, вы можете выполнить следующую команду:

    kafkacat -b <bootstrap_servers> -t <topic_name> -X config
  5. Получение смещений темы. Если вам нужно получить текущую информацию о смещении для каждого раздела темы, вы можете использовать эту команду:

    kafkacat -b <bootstrap_servers> -t <topic_name> -p 0 -o -2 -C

    Эта команда считывает последнее зафиксированное смещение (-2) из ​​раздела 0 указанной темы.

  6. Метаданные темы. Чтобы получить информацию о метаданных по теме, включая коэффициенты репликации и количество разделов, используйте следующую команду:

    kafkacat -b <bootstrap_servers> -M -t <topic_name>