centos7安装kafka

1、下载zookeeper，kafka需要依赖zookeeper，已经自带了一个zookeeper，也可以改成指定已运行的zookeeper

这里下载一个zookeeper

2、下载kafka

这里安装路径：/user/local/soft，下载链接：http://kafka.apache.org/downloads

进入页面选择一个版本：

 

 进入安装目录

cd /usr/local/soft

下载

wget https://mirror.bit.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz

解压，后面是包名

tar -xzvf kafka_2.13-2.5.0.tgz

3、修改配置文件

在解压目录下

vi config/server.properties

listeners改为本机的ip，取消注释

zookeeper改为指定的，不使用自带的zk,zookeeper.connect = zk的ip:port

num.partitions后面增加2行

#发送到不存在topic不自动创建
auto.create.topics.enable=false
#允许永久删除topic
delete.topic.enable=true

后台启动

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

4、发送消息

创建一个topic,名字为my_topic

sh bin/kafka-topics.sh --create --zookeeper 192.168.146.10:2181 --replication-factor 1 --partitions 1 --topic my_topic

查看已经创建的topic

sh bin/kafka-topics.sh -list -zookeeper 192.168.146.10:2181

启动Producer

sh bin/kafka-console-consumer.sh --bootstrap-server 192.168.146.10:9092 --topic my_topic--from-beginning

启动Consumer

sh bin/kafka-console-consumer.sh --bootstrap-server 192.168.146.10:9092 --topic my_topic--from-beginning

都重新再打开一个窗口，在解压目录下去执行这些命令，在Producer端发送消息，按enter键，Consumer就可以接受到消息了