21.6.6:安装kafka-2.8
说明:kafka 在设计上就是依赖于 zookeeper 的,所以启动 kafka 前需要启动 zookeeper
***zookeeper的安装:
zookeeper依赖于jdk环境
***先安装jdk
yum -y install java-1.8.0-openjdk-demo.x86_64
#验证一下是否安装成功
java -version
若java安装不成功,需要更换yum源
#备份初始源
#备份初始源配置
mv /etc/yum.repos.d/CentOS-Base.repo /etc/yum.repos.d/CentOS-Base.repo.backup
#下载新的阿里镜像源
wget -O /etc/yum.repos.d/CentOS-Base.repo http://mirrors.aliyun.com/repo/Centos-7.repo
#清理和重建索引
yum clean all
yum makecache
***开始安装zookeeper
wget https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz
tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz
mv apache-zookeeper-3.7.0-bin /usr/local
ln -s /usr/local/apache-zookeeper-3.7.0-bin /usr/local/zookeeper
# 添加至环境变量
echo export PATH=\"\$PATH:/usr/local/zookeeper/bin\" >> ~/.bashrc
#更新环境变量
source ~/.bashrc
目录说明:
/usr/local/apache-zookeeper-3.7.0-bin/bin 执行文件(.sh的文件是linux文件,.cmd文件是windows文件)
/usr/local/apache-zookeeper-3.7.0-bin/conf 配置文件
/usr/local/apache-zookeeper-3.7.0-bin/docs 文档
/usr/local/apache-zookeeper-3.7.0-bin/lib jars包
开始配置:
cd /usr/local/zookeeper/conf
cp zoo_sample.cfg zoo.cfg
vim zoo.cfg
tickTime=2000 #检测时间间隔
initLimit=10 主从连接超时时间
syncLimit=5 follower与leader同步超时时间
dataDir=/usr/local/zookeeper/data 存储节点id、地址、数据快照
clientPort=2181 对外服务的端口
maxClientCnxns=60 客户端对外连接的数量
启动、关闭、状态、查看、连接
启动:/usr/local/zookeeper/bin/zkServer.sh start
关闭:/usr/local/zookeeper/bin/zkServer.sh stop
状态:/usr/local/zookeeper/bin/zkServer.sh status
查看启动:ps aux|grep zoo
连接本机zoo:/usr/local/zookeeper/bin/zkCli.sh
连接其他机器:zkCli.sh -server 192.168.74.128:2181
配置集群版(更新中):
zoo.cfg中
server.1 = 192.168.74.129:28888:38888
server.2 = 192.168.74.130:28888:38888
server.3 = 192.168.74.131:28888:38888
***开始安装:
1)官网:http://kafka.apache.org/downloads
2)下载:https://downloads.apache.org/kafka/2.8.0/kafka_2.13-2.8.0.tgz
tar -zxvf kafka_2.13-2.8.0.tgz
mv kafka_2.13-2.8.0 /usr/local/
由于下载的是二进制包,所以解压后就算是安装好了,无需编译。
kafka 在设计上就是依赖于 zookeeper 的,所以启动 kafka 前需要启动 zookeeper
启动kafka:
/usr/local/kafka_2.13-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.13-2.8.0/config/server.properties
后台启动:
nohup /usr/local/kafka_2.13-2.8.0/bin/kafka-server-start.sh /usr/local/kafka_2.13-2.8.0/config/server.properties>>kafka.nohup &
端口:
创建topic:
/usr/local/kafka_2.13-2.8.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
创建一个名为test的topic,1个分区,每个分区分配1个副本
查看topic是否创建成功
/usr/local/kafka_2.13-2.8.0/bin/kafka-topics.sh -list -zookeeper localhost:2181
开始验证:
从producer端发送消息
查看consumer端接收到的消息
producer端:
/usr/local/kafka_2.13-2.8.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
consumer端:
/usr/local/kafka_2.13-2.8.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
能正常发送消息,能正常接收消息证明搭建成功
原文:https://www.cnblogs.com/shixiangqian/p/14856043.html