linux上kafka搭建小結
阿新 • • 發佈：2020-11-28
1、安裝java
yum -y list java
可以檢視java的版本，然後選1.8的64位那個安裝
yum install java_1.8.0_openjdk.x86_64
java安裝之後就開始設定環境變數
vi /etc/profile
#set java environment JAVA_HOME=/usr/lib/jvm/jre-1.8.0-openjdk-1.8.0.272.b10-1.el7_9.x86_64 PATH=$PATH:$JAVA_HOME/bin CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar export JAVA_HOME CLASSPATH PATH
使之生效命令
source /etc/profile
或者
. /etc/profile
2、 zookeeper
裝kafka的時候才知道，必須要先安裝zookeeper
從官網下載了3.5.5的包
http://archive.apache.org/dist/zookeeper/zookeeper-3.5.5/
tar zxvf apache-zookeeper-3.5.5-bin.tar.gz cd apache-zookeeper-3.5.5-bin cd conf cp zoo_sample.cfg zoo.cfg vi zoo.cfg
修改dataDir=後面的路徑，就改成程式路徑下，然後mkdirdata |cddata | mkdirzookeeper | mkdir log
修改環境變數/etc/profile
ZOOKEEPER_HOME=/root/hzt/apache-zookeeper-3.5.5-bin
PATH=$PATH:$ZOOKEEPER_HOME/bin
並生效
source /etc/profile
啟動程式
sh zkServer.sh start
停止命令把start改成stop就行。
測試下可以用windows的cmd
telnet 替換實際的機器ip 2181
或者linux下看狀態
shzkServer.shstatus
3、安裝kafka
從官網下載非原始碼版本的程式，帶有src安裝了會有問題
tar xzvf kafka_2.12-2.3.0.tgz
cdkafka_2.12-2.3.0
啟動程式
bin/kafka-server-start.sh config/server.properties &
檢測2181與9092埠
netstat -tunlp|egrep '(2181|9092)'
功能測試，新開一個視窗作為生產者
執行producer
bin/kafka-console-producer.sh --broker-list 192.168.1.1:9092 --topic test
再開一個視窗作為消費者
sh kafka_2.13-2.5.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.1:9092 --topic test --from-beginning
然後生產者介面輸入的內容會在消費者介面出現