Какие операции можно выполнять с помощью утилиты Kafka CLI?

Пользователь

от dayna , в категории: Другие , год назад

Какие операции можно выполнять с помощью утилиты Kafka CLI?

Facebook Vk Ok Twitter LinkedIn Telegram Whatsapp

2 ответа

Пользователь

от jorge , год назад

@dayna 

Утилита Kafka CLI (Command Line Interface) позволяет выполнять различные операции с Apache Kafka из командной строки. Некоторые из основных операций, которые можно выполнить с помощью Kafka CLI, включают:

  1. Создание топика: kafka-topics.sh --create --zookeeper <Zookeeper-адрес> --replication-factor <фактор-репликации> --partitions <число-партиций> --topic <название-топика>
  2. Список топиков: kafka-topics.sh --list --zookeeper <Zookeeper-адрес>
  3. Удаление топика: kafka-topics.sh --delete --zookeeper <Zookeeper-адрес> --topic <название-топика>
  4. Отправка сообщений в топик: kafka-console-producer.sh --broker-list <адрес-брокера> --topic <название-топика>
  5. Получение сообщений из топика: kafka-console-consumer.sh --bootstrap-server <адрес-брокера> --topic <название-топика> --from-beginning
  6. Просмотр информации о брокерах: kafka-broker-api-versions.sh --bootstrap-server <адрес-брокера> --command-config <конфигурационный-файл>
  7. Просмотр информации о группах потребителей: kafka-consumer-groups.sh --bootstrap-server <адрес-брокера> --list
  8. Изменение количества партиций топика: kafka-topics.sh --zookeeper <Zookeeper-адрес> --alter --topic <название-топика> --partitions <новое-число-партиций>


Это далеко не полный список операций, которые можно выполнять с помощью Kafka CLI. Утилита также позволяет выполнять множество других задач, включая создание консьюмеров, вывод логов и т.д. Для получения полного списка доступных команд и опций можно запустить Kafka CLI с параметром --help.

Пользователь

от ottilie.farrell , 3 дня назад

@dayna 

Некоторые другие операции, которые можно выполнить с помощью утилиты Kafka CLI, включают:

  • Создание новой консьюмер-группы: kafka-console-consumer.sh --bootstrap-server <адрес-брокера> --topic <название-топика> --group <название-группы>
  • Просмотр информации о консьюмер-группе: kafka-consumer-groups.sh --bootstrap-server <адрес-брокера> --describe --group <название-группы>
  • Изменение параметров консьюмера: kafka-consumer-groups.sh --bootstrap-server <адрес-брокера> --reset-offsets --to-earliest --execute --topic <название-топика> --group <название-группы>
  • Запуск и тестирование коннектора: connect-distributed.sh config/connect-distributed.properties


Это лишь несколько примеров операций, доступных с помощью Kafka CLI. Утилита обладает обширным набором функций для управления и мониторинга Apache Kafka, что позволяет администраторам эффективно управлять и контролировать свой кластер Kafka.