kafka安装

1.安装java环境

2.下载zookeeper和kafka包

zookeeper:https://zookeeper.apache.org/releases.html
kafka:http://kafka.apache.org/downloads

3.把下载包上传到服务器我的是centos7，目录是/home/software

4.安装zookeeper

4.1解压

tar -zxvf apache-zookeeper-3.5.7-bin.tar.gz
mv apache-zookeeper-3.5.7-bin zookeeper
mv zookeeper /usr/local
cd /usr/local/zookeeper/conf

4.2 复制配置文件

cd conf
cp zoo_sample.cfg zoo.cfg

4.3 修改配置文件

dataDir=/usr/local/zookeeper/data

4.4 创建目录

mkdir -p /usr/local/zookeeper/data

4.5 启动

/usr/local/zookeeper/bin/zkServer.sh start

4.6 进入

/usr/local/zookeeper/bin/zkCli.sh

5.安装kafka

4.1 解压

tar -zxvf kafka_2.11-2.4.0.tgz
mv kafka_2.11-2.4.0 kafka
mv kafka /usr/local/
cd /usr/local/kafka/config

4.2 修改配置文件

vim server.properties

listeners=PLAINTEXT://192.168.174.131:9092
advertised.listeners=PLAINTEXT://192.168.174.131:9092
log.dirs=/usr/local/kafka/logs
zookeeper.connect=localhost:2181

4.3 创建logs目录

mkdir -p /usr/local/kafka/logs

4.4 启动

bin/kafka-server-start.sh config/server.properties &

常用命令

1、启动Kafka
bin/kafka-server-start.sh config/server.properties &

2、停止Kafka
bin/kafka-server-stop.sh

3、创建Topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic jiangzh-topic

4、查看已经创建的Topic信息
bin/kafka-topics.sh --list --zookeeper localhost:2181

5、发送消息
bin/kafka-console-producer.sh --broker-list 192.168.174.131:9092 --topic jiangzh-topic

6、接收消息
bin/kafka-console-consumer.sh --bootstrap-server 192.168.174.131:9092 --topic jiangzh-topic --from-beginning