上面的步驟都執行完了,環境算是好了,下面我們要測試下是否能成功執行kafka:1. 啟動zookeeper server :bin/zookeeper-server-start.sh ../config/zookeeper.properties & (用&是為了能退出命令列)
2. 啟動kafka server: bin/kafka-server-start.sh ../config/server.properties &
3.
kafka為我們提供了乙個console來做連通性測試,下面我們先執行producer:bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic test 這是相當於開啟了乙個producer的命令列。命令列的引數我們一會兒再解釋。
4. 接下來執行consumer,新啟乙個terminal:bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5. 執行完consumer的命令後,你可以在producer的terminal中輸入資訊,馬上在consumer的terminal中就會出現你輸的資訊。有點兒像乙個通訊客戶端。
如果你能看到5執行了,說明你單機版部署成功了。下面解釋下兩條命令中引數的意思。--zookeeper localhost:2181 這個說明了去連本機2181埠的zookeeper server,--topic test,在kafka裡,訊息按topic來區分,我們這裡的topic叫test,所以不管是consumer還是producer都指向了test。其他的引數,我就截圖了,首先是producer的引數:
Kafka系列 Kafka常用命令
kafka系列文章 kafka系列 入門及應用場景 部署 簡單測試 kafka系列 kafka核心概念 問題1 當我們對test這個topic執行了這樣的刪除操作之後,傳送和接收資料的實驗還是否能夠成功?還是否能往裡面寫資料 讀資料呢?答案 能寫 能讀 問題2 配置了delete.topic.ena...
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...