@dayna
Утилита Kafka CLI (Command Line Interface) позволяет выполнять различные операции с Apache Kafka из командной строки. Некоторые из основных операций, которые можно выполнить с помощью Kafka CLI, включают:
- Создание топика: kafka-topics.sh --create --zookeeper <Zookeeper-адрес> --replication-factor <фактор-репликации> --partitions <число-партиций> --topic <название-топика>
- Список топиков: kafka-topics.sh --list --zookeeper <Zookeeper-адрес>
- Удаление топика: kafka-topics.sh --delete --zookeeper <Zookeeper-адрес> --topic <название-топика>
- Отправка сообщений в топик: kafka-console-producer.sh --broker-list <адрес-брокера> --topic <название-топика>
- Получение сообщений из топика: kafka-console-consumer.sh --bootstrap-server <адрес-брокера> --topic <название-топика> --from-beginning
- Просмотр информации о брокерах: kafka-broker-api-versions.sh --bootstrap-server <адрес-брокера> --command-config <конфигурационный-файл>
- Просмотр информации о группах потребителей: kafka-consumer-groups.sh --bootstrap-server <адрес-брокера> --list
- Изменение количества партиций топика: kafka-topics.sh --zookeeper <Zookeeper-адрес> --alter --topic <название-топика> --partitions <новое-число-партиций>
Это далеко не полный список операций, которые можно выполнять с помощью Kafka CLI. Утилита также позволяет выполнять множество других задач, включая создание консьюмеров, вывод логов и т.д. Для получения полного списка доступных команд и опций можно запустить Kafka CLI с параметром --help
.