Google Code Prettify

2018年8月11日 星期六

install Kafka (single node)

安裝 Apache Kafka 前要先安裝 jdkzookeeper,所以先下載 jdk、zookeeper 及 kafka,我下載的三個檔案為 jdk-8u181-linux-x64.tar.gz、zookeeper-3.4.12.tar.gz 及 kafka_2.12-2.0.0.tgz,放在 /home/steven 底下 (我自己的 home 目錄),用以下指令解開:
tar zxvf jdk-8u181-linux-x64.tar.gz
tar zxvf zookeeper-3.4.12.tar.gz
tar zxvf kafka_2.12-2.0.0.tgz
然後搬到 /usr/local/bin 目錄下,這是我的個人習慣,自己安裝的軟體就放這個目錄。暫且我們稱這三個目錄為 $JAVA_HOME、$ZOOKEEPER 及 $KAFKA。要怎麼設定 JAVA_HOME,可以參考這一篇 -- 「安裝 JDK」。
  • 安裝 zookeeper
進入 $ZOOKEEPER/conf 目錄,可以看到 zoo_sample.cfg 設定檔的 sample,複製一份到 zoo.cfg,這是 zookeeper 預設的設定檔檔名。
cp zoo_sample.cfg zoo.cfg
然後回到 $ZOOKEEPER 目錄,執行以下 bin/zkServer.sh start 指令,看到如下訊息,就表示 zookeeper 啟動了。
ZooKeeper JMX enabled by default
Using config: /usr/local/bin/zookeeper-3.4.12/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED
要查看 server 的狀態,可以用 telnet localhost 2181 (2181 為預設的 port),進入 server 後下 srvr 指令,就可以顯示出 server 的狀態了。
[root@localhost ~]# telnet localhost 2181
Trying ::1...
Connected to localhost.
Escape character is '^]'.
srvr
Zookeeper version: 3.4.12-e5259e437540f349646870ea94dc2658c4e44b3b, built on 03/27/2018 03:55 GMT
Latency min/avg/max: 0/0/0
Received: 1
Sent: 0
Connections: 1
Outstanding: 0
Zxid: 0x0
Mode: standalone
Node count: 4
Connection closed by foreign host.
  • 安裝 Kafka
進入 $KAFKA 目錄,下以下的指令:
bin/kafka-server-start.sh config/server.properties
如果要啟動背景模式,指令如下:
bin/kafka-server-start.sh -daemon config/server.properties

沒有留言:

張貼留言