bin/kafka-topics.sh --create --bootstrap-server hadoop102:9092 --topic test
bin/kafka-console-producer.sh --broker-list hadoop102:9092
在本節點建立乙個生產者
bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic test
然後複製此會話,重新建立乙個消費者
可以看出,當生產者產生資料的時候,消費者可以讀取資訊,
Kafka集群的簡單使用(shell)
kafka本地集群搭建完成,介紹在shell中進行簡單使用,並記錄。cd opt zookeeper bin zkserver.sh startcd opt kafka bin kafka server start sh config server.properties 表示後台執行,這樣就可以啟動...
Kafka集群部署及簡單使用
1 解壓安裝包 atguigu hadoop102 software tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 2 修改解壓後的檔名稱 atguigu hadoop102 module mv kafka 2.11 0.11.0.0 kafka 3 在...
Kafka集群簡單介紹
2 上傳linux並解壓 tar zxvf kafka 2.11 1.0.0.tgz 3 修改server.properties檔案 1 配置kafka儲存位置,要配置為非 tmp目錄 log.dirs 非 tmp目錄 4 修改zookeeper.properties檔案 1 kafka內建了乙個z...