kafka簡單的啟動命令
我這裡的安裝目錄是：/home/bigdata/kafka ， 節點名稱為 localhadoop1
進入安裝目錄後輸入
bin/kafka-server-start.sh config/server.properties &(後臺執行)
bin/kafka-server-start.sh config/server.properties (執行)
啟動
生產者模式
bin/kafka-console-producer.sh --broker-list localhadoop1:9092 --topic accesslog
消費者模式
bin/kafka-console-consumer.sh --zookeeper localhadoop1:2181 --from-beginning --topic mobile
建立topic
bin/kafka-topics.sh --create --zookeeper localhadoop1:2181 --replication-factor 1 --partitions 1 --topic mobile
檢視當前伺服器中的所有topic
bin/kafka-topics.sh --list --zookeeper localhadoop1:2181
檢視topic
sh
刪除topic
bin/kafka-topics.sh --delete --zookeeper localhadoop1:2181 --topic test
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。