一、打开Kafka官网进行下载Kafka
官网地址:https://kafka.apache.org/downloads
我下载的版本是3.5.0
二、下载完毕之后进行解压
因为Kafka的运行依赖于 Zookeeper,所以还需要下并安装Zookeeper,ZooKeeper和Kafka版本之间有一定的对应关系,不同版本的ZooKeeper和Kafka可以相互兼容,但需要满足一定的条件。
Kafka 2.2.0 开始支持使用内置的ZooKeeper替代外部ZooKeeper。 所以3.5.0是不需要安装Zookeeper的,直接解压即可。
三、启动Zookeeper
因为Kafka中的Broker注册,Topic注册,以及负载均衡都是在Zookeeper中管理,所以需要先启动内置的Zookeeper
打开Conf文件下的zookeeper.properties文件,修改dataDir目录路径
执行启动Zookeeper命令 .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
当看到绑定到IP地址为0.0.0.0、端口号为2181的地址,表示ZooKeeper服务器监听在该地址,启动成功
四、启动Kafka 修改Conf下的server.properties文件,修改kafka的日志文件路径
新开一个命令行窗口,在之前的目录中输入启动命令 .\bin\windows\kafka-server-start.bat .\config\server.properties
五、测试kafka 在之前的目录中,新开一个命令行,进行创建名为“test2”的主题,其包含一个分区,只有一个副本 .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test2
创建一个生产者来产生数据 .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test2
创建消费者消费数据 输入以下命令,然后回车 .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test2 --from-beginning
然后在之前的生产者窗口中发送数据,消费者窗口即可消息数据,如下所示
来源:https://new-developer.aliyun.com/article/1256736
标签:bin,ZooKeeper,Windows,Zookeeper,kafka,--,Kafka,安装 From: https://www.cnblogs.com/ywtssydm/p/17582694.html