脚本宝典收集整理的这篇文章主要介绍了Kafka集群部署,脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。
systemctl stop firewalld
setenforce 0
下载kafka包并解压
yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel
yum install -y wget
下载 : wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz --no-check-certificate解压 :tar xvf kafka_2.12-3.0.0.tgz -C /root/
编辑文件内容
vi /root/kafka_2.12-3.0.0/config/server.properties
在文件末尾添加下面的内容( broker.id=一节点是1,二节点是2.。。。。。IP1,2,3为三台节点IP,listeners中输入当前节点IP地址)
broker.id=1
zookeeper.connect=IP1:2181,IP2:2181,IP3:2181
listeners = PLAINTEXT://当前节点IP:9092
启动服务:
/root/kafka_2.12-3.0.0/bin/kafka-server-start.sh -daemon /root/kafka_2.12-3.0.0/config/server.properties查看服务是否启动
jps << 命令
测试:
(在第一节点运行): /root/kafka_2.12-3.0.0/bin/kafka-topics.sh --create --zookeeper 172.16.51.23:2181 --replication-factor 1 --partitions 1 --topic test
(在第二节点运行): /root/kafka_2.12-3.0.0/bin/kafka-topics.sh --list --zookeeper 二节点IP:2181
(在第三节点运行): /root/kafka_2.12-3.0.0/bin/kafka-topics.sh --list --zookeeper 三节点IP:2181
以上是脚本宝典为你收集整理的Kafka集群部署全部内容,希望文章能够帮你解决Kafka集群部署所遇到的问题。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。