Kafka的安裝和簡單例項測試及遇到的問題

2021-09-23 18:42:00 字數 1364 閱讀 2274

安裝的命令如下：

這樣，kafka基本就算是安裝好了。接下來，進行一些簡單的測試：

首先新開啟乙個終端，輸入：

cd /usr/local/kafka

bin/zookeeper-server-start.sh config/zookeeper.properties

這個目的是啟動zookeeper伺服器。

接著，再開啟乙個新的終端：

cd /usr/local/kafka

bin/kafka-server-start.sh config/server.properties

這個目的是啟動kafka伺服器。

接下來，再開啟乙個新的終端：

cd /usr/local/kafka

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

topic是發布訊息發布的category,以單節點的配置方式建立了乙個名為test的topic。

輸入下面的命令，可以檢視test這個topic已存在了。

bin/kafka-topics.sh --list --zookeeper localhost:2181

接下來用producer生產點資料：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

執行上面的命令之後，可以在終端輸入一些資訊作為測試：

hello world

hello kafka

然後再次開啟新的終端或者直接按ctrl+c退出。然後使用consumer來接收資料,輸入如下命令：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

注：kafka0.90版本之後啟動消費者的方法： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning，而之前的版本的啟動consumer的命令是：bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic dblab --from-beginning

Kafka安裝和簡單使用

首先安裝zookeeper和scala 安裝zookeeper root hadoop001 conf cp zoo sample.cfg zoo.cfg root hadoop001 conf vi zoo.cfg the number of milliseconds of each tick t...

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...