Zookeeper与Kafka集群搭建完整教程

1、首先我们需要在官网上下载好我们需要的kafka，zookeeper版本的安装包。如图，百度搜索zookeeper，点击红圈所示链接进入官网，按照下图步骤点击相应红圈处，到http链接下载随意点击一个下载链接即可，本人是点击最上面的推荐链接，然后进入下载链接后选择对应版本进去进行下载。

2、下载好zookeeper版本后，继续下载kafka。同样百度搜索kafka，进入官网，步骤如下图所示，一步一步来，到最后选择要下载的版本，进行下载。

3、下载完成后，如下图所示

5、解压完成后，可配可不配环境变量，若配的话，vim /etc/profile 下在最后加上export ZOOKEEPER_HOME=/yybTest/zookeeperexport PATH=$PATH:$ZOOKEEPER_HOME/bin然后，进入到zookeeper的conf目录下修改他的zoo.cfg文件，若没有则将zoo_sample.cfg复制一份改名zoo.cfg,指令是cpzoo_sample.cfg zoo.cfg用vimzoo.cfg进入：一般来说最多修改以下配置，特殊要求除外clientPort=2181zookeeper的端口号，注：修改后对应kafka处也要修改　　 dataDir=/yybTest/zookeeper/data 保存数据目录　　dataLogDir=/yybTest/zookeeper/log 保存日志目录 server.1=ip:2888:3888 ip为服务器的ip　　 server.2=ip:2888:3888 ip为服务器的ip　　 server.3=ip:2888:3888 ip为服务器的ip具体如下图：此处我修改了zk的端口号，因为我安装了多个zk，kafka集群

8、创建一个kafka的topic在kafka_1.20-0.10.1.0下：bin/kaf氯短赤亻ka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test_topic可通过命令：bin/kafka-topics.sh --list --zookeeper localhost:2181查看topic是否创建成功创建一个console的producer在kafka_1.20-0.10.1.0下：bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test_topic创建一个console的consumer在kafka_1.20-0.10.1.0下：bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test_topic --from-beginning查看是否消费到producer创建的消息

9、至此，kafka，zk的集群下载搭建，以及验证就全部完成了。