一、centos7安装java8
去官网下载
代码语言：javascript复制tar -zxvf jdk-8u281-linux-x64.tar.gz
mkdir /usr/java
mv jdk1.8.0_281 /usr/java环境变量配置：
打开/etc/profile配置文件
代码语言：javascript复制vi /etc/profile在配置文件末尾添加如下配置：
代码语言：javascript复制export JAVA_HOME=/usr/java/jdk1.8.0_281
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin使用source命令使环境变量修改立即生效：
代码语言：javascript复制source /etc/profile二、Zookeeper安装
去官网下载最新版zookeeper服务：https://zookeeper.apache.org/releases.html
代码语言：javascript复制tar zxvf apache-zookeeper-3.7.0-bin.tar.gz 将conf目录下zoo_sample.cfg配置文件更改为zoo.cfg配置，然后就可以启动zookeeper服务器了：
在apache-zookeeper-3.7.0-bin统计目录创建zookeeper/data目录存放数据，修改zoo.cfg配置为：
代码语言：javascript复制#zookeeper数据存放目录修改
dataDir=/emis/kafka/zookeeper/data
#集群配置 server.A=B:C:D
# A是一个数字，代表服务器的编号，就是data目录下myid里面的数字
# B是服务器IP地址
# C是服务器与集群中leader服务器交换信息的端口
# D选举时服务器相互通信的端口
server.1=xx.xx.xx.xx:2888:3888
server.2=xx.xx.xx.xx:2888:3888
server.3=xx.xx.xx.xx:2888:3888在data文件夹下创建myid文件内部输入服务器标识:
代码语言：javascript复制# 在/emis/kafka/zookeeper/data下新建myid文件，并添加服务器标识，是上述A代表的数字
vi myid# 启动服务器
bin/zkServer.sh start
# 停止服务器
bin/zkServer.sh stop
# 进入CLI操作命令
bin/zkCli.sh
# 查看集群状态
bin/zkServer.sh status环境配置：
代码语言：javascript复制vi /etc/profile
# 添加如下配置
export ZOOKEEPER_HOME=/xxx/kafka/apache-zookeeper-3.7.0-bin
export PATH=$PATH:$ZOOKEEPER_HOME/bin
# 使环境配置立马生效
source /etc/profile三、kafka下载安装
去官网下载最新版本：http://kafka.apache.org/downloads
解压缩kafka
代码语言：javascript复制tar zxvf kafka_2.12-2.7.0.tgz修改配置：
代码语言：javascript复制# 创建目录
/opt/kafka/logs
# 修改配置
vi config/server.properties
# broker的编号，如果集群中有多个broker,则每个broker的编号需要设置的不同，同zookeeper一致就可以
broker.id=0
# 存放消息日志文件地址
log.dirs=/opt/kafka/logs
# broker对外提供服务的入口地址
advertised.listeners=PLAINTEXT://10.10.XX.xx:9092
# Kafka所需要的Zookeeper集群地址
zookeeper.connect=xx.xx.XX.xx:2181,xx.xx.XX.xx:2181,xx.xx.XX.xx:2181Kafka常用命令：
代码语言：javascript复制# 启动Kafka
bin/kafka-server-start.sh -daemon config/server.properties
# 停止kafka
bin/kafka-server-stop.sh
# 查看kafka进程
jps验证Kafka集群是否搭建成功：
代码语言：javascript复制# 生产者
bin/kafka-console-producer.sh --broker-list xx.xx.xx.xx:9092 --topic test
# 消费者
bin/kafka-console-consumer.sh --bootstrap-server xx.xx.xx.xx:9092 --topic test --from-beginningGitHub地址：https://github.com/mingyang66/spring-parent
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/183958.html原文链接：https://javaforall.cn
