工作需要,本地搭建了kafka的集群做测试,并简单使用。

本地环境:
- VMware Workstation 14 Pro
- CentOS 7
<http://isoredirect.centos.org/centos/7/isos/x86_64/CentOS-7-x86_64-DVD-1708.iso>
- jdk-8u161-linux-x64.tar.gz
<http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html>
- zookeeper-3.4.10.tar.gz <https://www.apache.org/dyn/closer.cgi/zookeeper/>
- kafka_2.11-1.0.1.tgz <http://kafka.apache.org/downloads>

主机名 IP 软件
tyron0 192.168.1.100 jdk 8、zookeeper-3.4.10、kafka-1.1.0
tyron1 192.168.1.101 jdk 8、zookeeper-3.4.10、kafka-1.1.0
tyron2 192.168.1.102 jdk 8、zookeeper-3.4.10、kafka-1.1.0


环境搭建

可以参考我之前的文章:VMware14搭建CentOS+jdk8环境
<https://blog.csdn.net/tian330726/article/details/79868407>

zookeeper安装

参考教程:认识 ZooKeeper-极客学院 <http://www.jikexueyuan.com/course/1813.html>
附上配置文件:

// 启动zookeeper cd /opt/zookeeper/bin/ ./zkServer.sh start

注意事项:三台虚拟机开启2888、3888端口
firewall-cmd --zone=public --add-port=2888/tcp --permanent firewall-cmd --
zone=public --add-port=3888/tcp --permanent systemctl restart firewalld.service
搭建过程中出现的问题:启动ZooKeeper出错及解决方法
<https://blog.csdn.net/tian330726/article/details/79876583>

kafka安装

kafka安装相对简单与zookeeper安装类似,主要是修改配置文件:
broker.id=0 //依次增长的:0、1、2、3、4,集群中唯一id host.name=192.168.1.100 //
主机ip,分别是101和102 port=9092 //端口号 log.dirs=/opt/kafka/logs // 日志地址
zookeeper.connect=192.168.1.100:2181,192.168.1.101:2181,192.168.1.102:2181
//zookeeperServers列表,各节点以逗号分开 // 启动kafka cd /opt/kafka/ bin/kafka-server-start.
sh-daemon config/server.properties & // 可能会有权限不足 chmod +x kafka-server-stop.sh
启动成功后,如本文第一张图所示。

参考文档:
kafka学习 非常详细的经典教程 <http://www.uml.org.cn/bigdata/201801112.asp>
Kafka教程(二)Kafka集群环境安装 <https://blog.csdn.net/yuan_xw/article/details/79188061>

友情链接
KaDraw流程图
API参考文档
OK工具箱
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:[email protected]
QQ群:637538335
关注微信