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 &