基础要求操作系统:CentOS 7x 64位 kafka版本:kafka_2.11-0.8.2.1
#安装使用的jdk以及kafka的包我放到百度云了,需要自取。
# 链接:https://pan.baidu.com/s/1k-Z0u09FRE_4bUbrePLStQ
提取码:ns3c
1、关闭selinux 开放防火墙9092端口
[root@wzy-x ~]# vi /etc/selinux/config
[root@wzy-x ~]# tail -2 /etc/selinux/config
SELINUX=disabled
[root@wzy-x ~]# setenforce 0 #不重启情况下临时生效
[root@wzy-x ~]# getenforce #查看状态
Permissive
开放防火墙9092端口
将jdk解压到 /uer/local/src
解压后改名为jdk方便后面使用
添加jdk到系统变量
应用到系统变量并查看jdk版本
上传kafka到 /usr/local/src 下,并解压
mkdir /usr/local/kafka ,将kafka移动到 /usr/local/kafka
#因为是单机安装,所以不需要修改配置文件,保持默认
启动zookeeper #启动脚本在 /usr/local/kafka/kafka_.../bin/
启动kafka
验证kafka
cd /usr/local/kafka
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test #创建topic
验证topic创建是否成功,成功输出test。
模拟生产者发送消息
再开启一个ssh连接,模拟消费者
至此服务就安装成功了。