一、安装JDK

过程比较简单,就不在详细说明

二、安装zookeeper
# 1.下载安装包
https://zookeeper.apache.org/releases.html#download
# 2.下载下来的就长这样如下:

在这里插入图片描述

# 3.直接解压,然后进入它的conf目录下,将`zoo_example.cfg`重命名为`zoo.cfg`,如图

在这里插入图片描述

# 4.这里我使用`notepad++`打开`zoo.cfg`,找到dataDir,修改数据存放路径(可以自定义)
# 注意:路径中不得有空格

在这里插入图片描述

# 5.和JDK安装类似,在系统环境变量中添加`%ZOOKEEPER_HOME%`,设置自己的zk安装路径,然后在用户变量中添加%ZOOKEEPER_HOME%\bin

在这里插入图片描述
在这里插入图片描述

# 6.同样还是在`zoo.cfg`文件中,修改默认的zk端口号,默认2181,我们也可以不修改
# 7.随便打开一个cmd窗口,哪里打开都行,因为我们已经设置了环境变量,输入`zkserver`,运行zookeeper

在这里插入图片描述

三、安装与运行Kafka
# 1.先下载kafka,地址如下,注意需要下载二进制版本
http://kafka.apache.org/downloads.html
# 2.下载下来长这样

在这里插入图片描述

# 3.同样,还是直接解压,然后进入config目录,编辑server.properties,设置log路径

在这里插入图片描述

# 4.server.properties中还包含有zookeeper的连接配置,有需求的自己改,默认本机2181端口

在这里插入图片描述

# 5.运行kafka,注意,运行前需要保证zookeeper已经在运行
1. 进入kafka的安装目录,如我这里是`E:\IDEA2018.3.5\kafka_2.12-2.8.0`
2. 在此处打开cmd窗口
3. 输入`.\bin\windows\kafka-server-start.bat .\config\server.properties`,然后回车
4. 运行成功,不要关闭,继续下面的操作需要运行kafka
四、kafka的简单使用
# 注意:zookeeper不能关闭,上一步启动的kafka不能关闭
# 1.创建主题
# 进入kafka安装目录下的bin\windows\目录下打开cmd,输入下面命令,创建topic,名称为test0818
`kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test0818`
# 2.创建生产者,在kafka安装目录下的bin\windows\目录下
`kafka-console-producer.bat --broker-list localhost:9092 --topic test0818`

在这里插入图片描述

# 3.创建消费者,在kafka安装目录下的bin\windows\目录下
`kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test0818  --from-beginning`

在这里插入图片描述

# 4.此时再从生产者端中输入消息,消费者端就会自动拉取
1. 除此之外,你可以尝试先关闭或者先不启动消费者端,在生产者端多输入几次消息,然后再启动消费者端,它会将你在生产者端输入的消息全部拉取过来
Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐