Linux搭建kafka

1、安裝Java

一、查看linux 的系統版本

root@aliyun:~# uname --m
x86_64

二、安裝java

mkdir -p /usr/local/java
tar -xf jdk-8u181-linux-x64.tar.gz
mv jdk1.8.0_181 java

vim ~/.bashrc

#set oracle jdk environment
export JAVA_HOME=/usr/local/java  ## 這裏要注意目錄要換成本身解壓的jdk 目錄
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
export PATH=${JAVA_HOME}/bin:$PATH



update-alternatives --install /usr/bin/java java /usr/local/java/bin/java 300  
update-alternatives --install /usr/bin/javac javac /usr/local/java/bin/javac 300  
update-alternatives --install /usr/bin/jar jar /usr/local/java/bin/jar 300   
update-alternatives --install /usr/bin/javah javah /usr/local/java/bin/javah 300   
update-alternatives --install /usr/bin/javap javap /usr/local/java/bin/javap 300

source ~/.bashrc

三、查看本身的java版本

root@aliyun:/usr/local# java -version
java version "1.8.0_181"
Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)

2、安裝zookeeper

wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz
tar -xf zookeeper-3.4.10.tar.gz
mv zookeeper-3.4.10 zookeeper
cd zookeeper/src/c
./configure
make && make install

3、安裝Kafka

wget http://mirror.bit.edu.cn/apache/kafka/2.0.0/kafka_2.11-2.0.0.tgz
mv kafka_2.11-2.0.0.tgz kafka
tar -xf kafka_2.11-2.0.0.tgz
mv kafka_2.11-2.0.0 kafka

4、設置zookeeper 和 kafka的全局命令

vim ~/.bashrc

export PATH=/usr/local/kafka/bin:/usr/local/zookeeper/bin:$PATH

source ~/.bashrc

啓動服務

一、啓動zookeeper

zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties >> /dev/null &

二、啓動kafka

kafka-server-start.sh /usr/local/kafka/config/server.properties >> /dev/null &

三、生產一個TOPIC

kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test

四、消費一個TOPIC

kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test