1. 程式人生 > >kafka topic 命令操作

kafka topic 命令操作

bin/kafka-topics.sh --list --zookeeper localhost:2181(檢視topic)

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topictest --from-beginning(檢視topic內資料)

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test(刪除topic內資料)

如果kafaka啟動時載入的配置檔案中server.properties沒有配置"delete.topic.enable=true",那麼此時的刪除並不是真正的刪除,而是把topic標記為刪除:marked for deletion