1. 程式人生 > >Linux 單節點部署kafka

Linux 單節點部署kafka

1、驗證是否裝有java環境

      $ java -version

   如果java在您的機器上成功安裝,可以看到已安裝的Java的版本。如果為安裝請先安裝java JDK,這裡不做說明。

2、安裝ZooKeeper。

下載ZooKeeper,wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

解壓:tar -zxvf zookeeper-3.4.10.tar.gz

建立data目錄:cd zookeeper-3.4.10
                         mkdir data
複製zoo_sample.cfg 為 zoo.cfg
cd zookeeper-3.4.10/conf
cp zoo_sample.cfg zoo.cfg  

配置zoo.cfg內容:
vi conf/zoo.cfg
tickTime=2000
dataDir=/path/to/zookeeper/data
clientPort=2181
initLimit=5
syncLimit=2

啟動zookeeper
bin/zkServer.sh start

啟動CLI
bin/zkCli.sh

停止Zookeeper伺服器
 bin/zkServer.sh stop

3、安裝kafka
下載kafka:
wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/0.11.0.2/kafka_2.11-0.11.0.2.tgz

解壓:
tar -zxvf kafka_2.11-0.11.0.2.tgz

配置記憶體:
vi kafka_2.11-0.11.0.2/bin/kafka-server-start.sh

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx256m -Xms256m"
fi

修改對外的IP地址,否則kafka在別的機器上無法釋出和訂閱 :

vi kafka_2.11-0.11.0.2/config
advertised.listeners=PLAINTEXT://對外IP
listeners=PLAINTEXT://:9092     這個預設是註釋掉的 要放開

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

後臺啟動

./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>&1 &