Конфигурация топика kafka
Все переопределённые значения конфигурации топика
kafka-configs.sh --bootstrap-server kafka:9092 --describe --entity-type topics --entity-name my-topic
more kafka
all 20 commands →
Задать retention топика
kafka-configs.sh --bootstrap-server kafka:9092 --alter --entity-type topics --entity-name my-topic --add-config retention.ms=604800000
Метаданные брокера
kafka-broker-api-versions.sh --bootstrap-server kafka:9092
Список топиков
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>