Centos7安装kafka及测试-稳！

部署/安装kafka

下载安装包 oracle官网jdk下载 apache官网kafka下载 jdk安装包要根据自己的操作系统下载，centos选这个

kafka压缩包选【.tgz】文件，不要选【src.tgz】文件

将下载好的包上传到centos

安装jdk(java环境)

rpm -ivh jdk-15.0.1_linux-x64_bin.rpm

解压kafka(解压就行，免安装的) tar -zxvf kafka_2.11-2.4.1.tgz

启动zookeeper cd kafka_2.11-2.4.1 bin/zookeeper-server-start.sh config/zookeeper.properties & #停止zookeeper：bin/zookeeper-server-stop.sh 稍等十几秒，可以通过jps命令查看是否启动成功，如下

若要想配置zookeeper相关的日志目录、端口等信息，可以修改此文件config/zookeeper.properties vi config/zookeeper.properties

配置kafka启动文件 cp config/server.properties config/server.properties-1 vi config/server.properties-1 修改以下内容 broker.id=1 #brocker id号，通过此来区分不同brocker listeners=PLAINTEXT://:9093 #端口号 advertised.listeners=PLAINTEXT://172.20.10.87:9093 #ip+端口号 log.dirs=/tmp/kafka-logs-1 #日志目录 启动kafka bin/kafka-server-start.sh config/server.properties-1 & #关闭kafka：bin/kafka-server-stop.sh 稍等几十秒，执行成功，如下

测试

创建主题topic bin/kafka-topics.sh --create --zookeeper 172.20.10.87:2181 --replication-factor 1 --partitions 1 --topic test1 & #删除主题：bin/kafka-topics.sh --delete --zookeeper 172.20.10.87:2181 --topic test2 查看主题topic列表 bin/kafka-topics.sh --list --zookeeper 172.20.10.87:2181 可以查到所创建的主题

生产、消费测试 打开两个shell终端，一个用作生产，一个用作消费 #生产的窗口执行： bin/kafka-console-producer.sh --broker-list 172.20.10.87:9093 --topic test1 #消费的窗口执行： bin/kafka-console-consumer.sh --bootstrap-server 172.20.10.87:9093 --topic test1 --from-beginning #老版本kafka用：bin/kafka-console-consumer.sh --zookeeper 172.20.10.87:2181 --topic test1 --from-beginning 效果如下

参考文章： centos7单机安装kafka，进行生产者消费者测试 https://www.cnblogs.com/jstarseven/p/11364852.html CentOS7安装和使用kafka https://blog.csdn.net/zzq900503/article/details/83348419 kafka搭建以及server-properties配置说明 https://blog.csdn.net/sinat_32023305/article/details/83860441 文章内容如有纰漏，请留言，多谢