Метаданные брокера kafka
Список всех API версий поддерживаемых брокером
kafka-broker-api-versions.sh --bootstrap-server kafka:9092
more kafka
all 20 commands →
Список топиков
kafka-topics.sh --bootstrap-server kafka:9092 --list
Создать топик
kafka-topics.sh --bootstrap-server kafka:9092 --create --topic <name> --partitions 3 --replication-factor 2
Описание топика
kafka-topics.sh --bootstrap-server kafka:9092 --describe --topic <name>
Удалить топик
kafka-topics.sh --bootstrap-server kafka:9092 --delete --topic <name>
Читать топик с начала
kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic <name> --from-beginning