kafka的一些基本命令
啟動zookeeper
./zkserver start.sh ./config/zookeper.properties
啟動kafka
./zkfka-server-start.sh config/server.properties
此處topic名稱以test為例
容易出錯的地方localhost:2181此處需和server.properties中的配置相吻合
建立topic
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查詢topic列表
./kafka-topics.sh --list --zookeeper localhost:2181
啟動 producer(生產者)
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
啟動 consummer
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
topic的資訊
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
Kafka安裝測試
wget 2 上傳至linux下並解壓 3 啟動服務 3.1 啟動zookeeper 啟動zk有兩種方式，第一種是使用kafka自己帶的乙個zk。bin zookeeper server start.sh config zookeeper.properties 另一種是使用其它的zookeeper，...
kafka安裝及其測試
解壓命令 tar zxvf 檔案安裝包 4 1 zookeeper後台啟動 zookeeper server start.sh daemon opt kafka kafka 2.11 1.0.0 config zookeeper.properties 4 2 kafka後台啟動 kafka serv...
Kafka安裝與測試
tar zxf kafka 2.11 2.1.0.tgz c usr local sudo mv usr local kafka 2.11 2.1.0.tgz usr local kafka sudo chown r hadoop usr local kafka 啟動zookeeper cd usr...