kafka單機部署文檔

單機Kafka部署文檔

最簡單的使用方式,單機,使用自帶的zookeeper

1.解壓

tar –zxvf kafka_2.10-0.10.0.1.tgz

2.修改配置

vim config/server.properties
修改項以下(有則修改,無則添加):
host.name=你的ip
listeners=PLAINTEXT://你的ip:9092
advertised.listeners=PLAINTEXT://你的ip:9092
zookeeper.connect=你的ip:2181

3.啓動 (nohub 和 最後的 &都是爲了後臺啓動,避免ctrl+c 或者關閉連接而kill)

啓動zookeeper:nohup bin/zookeeper-server-start.sh config/zookeeper.properties 1>zookeeper.log 2>zookeeper.err &
啓動kafka:nohup bin/kafka-server-start.sh config/server.properties &

4.建立topic 並查看

建立topic:bin/kafka-topics.sh --create --topic test --replication-factor 1 --partitions 1 --zookeeper Slave1:2181
查看list:bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --list

5.驗證(收發消息)

發:bin/kafka-console-producer.sh --broker-list 你的IP:9092 –topic test
收:bin/kafka-console-consumer.sh --zookeeper  127.0.0.1:2181  --from-beginning --topic test

6.可能存在的問題

啓動失敗
  1. 報錯說沒有log.dirs=/tmp/kafka-logs,這個目錄沒有寫權限,這時就得ll檢查一下權限了,好比我用root安裝,用work啓動,就會遇到此問題
  2. 收不到消息:連不上zookeeper,可是zookeeper進程在,多是由於 步驟2 沒有修改IP,緣由是kafk會自動獲取,可能會獲取出錯。
  3. 假死:進程在,可是沒法使用,或者調用 bin/zookeeper-server-stop.sh 和bin/kafka-server-stop.sh後進程依然在,就ps –ef | grep kafka , ps –ef | grep zookeeper手動kill -9 一下
相關文章
相關標籤/搜索