建立topic：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
展示topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
描述topic
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
控制台生產者：
bin/kafka-console-producer.sh --broker-list 130.51.23.95:9092 --topic my-replicated-topic
控制台消費者：
bin/kafka-console-consumer.sh --zookeeper 130.51.23.95:2181 --topic test --from-beginnin
刪除topic：
bin/kafka-topics.sh --delete --zookeeper 130.51.23.95:2181 --topictopicname
刪除topic中儲存的內容在config/server.properties中找到log.dirs，刪除指定檔案，重啟kafka即可
查詢topic的offset的範圍：
最小值——bin/kafka-run-class.sh kafka.tools.getoffsetshell --broker-list suna:9092 -topic test --time -2
最大值——bin/kafka-run-class.sh kafka.tools.getoffsetshell --broker-list suna:9092 -topic test --time -1
docker常用命令匯集
結束所有執行的容器 docker kill docker ps a q 刪除所有已經停止的容器 docker rm docker ps a q 刪除所有未打 dangling 標籤的映象 docker rmi docker images q f dangling true 刪除所有映象 docker...
kafka常用命令
kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...
kafka常用命令
啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...