你的位置：
首页
>
业界
>
Windows系统下搭建Kafka
Windows系统下搭建Kafka
- kafka简介
- 安装JDK
- 安装zookeeper
- 安装Kafka
- kafka演示
- 创建主题
- 创建生产者
- 创建消费者
- 生产者发送消息，消费者消费消息
kafka简介
Kafka是一个分布式发布——订阅消息传递系统，它最初是由LinkedIn公司开发的，之后成为Apache项目的一部分。Kafka快速、可扩展且耐用。它保留主题中的消息源。生产者将数据写入主题，消费者从主题中读取数据。Kafka是一个分布式，可划分的，冗余备份的持久性的日志服务，它主要用于处理流式数据。具有横向扩展，容错，wicked fast(变态快)等优点，并已在成千上万家公司运行。
详细可查看官网：http://kafka.apache/
安装JDK
- JDK下载路径
- 按照网上参考步骤，依次配置JAVA_HOME、Classpath和Path，然后打开cmd，运行java -version成功，则JDK配置成功；
安装zookeeper
参考： Windows系统ZooKeeper集群环境搭建
安装Kafka
-
Kafka下载路径
-
下载步骤
(1) 请求Kafka下载路径
(2) 注意要下载二进制版本的, 点击下图圈红链接
(3) 点击点击下图圈红链接进行下载
-
下载后解压到任意一个目录，此处我解压的目录是：D:\ruanjian\kafka_2.13-2.5.0
-
修改配置文件
进入目录：D:\ruanjian\kafka_2.13-2.5.0\config，编辑文件"server.properties"
注意：配置文件中：zookeeper.connect=localhost:2181 是zookeeper的服务地址，请与上面已安装zookeeper服务的地址与端口保持一致。kafka会按照默认配置，在9092端口上运行，并连接zookeeper的默认端口2181。
-
启动Kafka服务
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
(4) 执行成功后日志如下图：
kafka演示
创建主题
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mumu
(4) 执行成功后日志如下图：
创建生产者
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic mumu
(4) 执行成功后日志如下图：
创建消费者
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mumu
(4) 执行成功后日志如下图：
生产者发送消息，消费者消费消息
到此kafka安装成功！
Windows系统下搭建Kafka
- kafka简介
- 安装JDK
- 安装zookeeper
- 安装Kafka
- kafka演示
- 创建主题
- 创建生产者
- 创建消费者
- 生产者发送消息，消费者消费消息
kafka简介
Kafka是一个分布式发布——订阅消息传递系统，它最初是由LinkedIn公司开发的，之后成为Apache项目的一部分。Kafka快速、可扩展且耐用。它保留主题中的消息源。生产者将数据写入主题，消费者从主题中读取数据。Kafka是一个分布式，可划分的，冗余备份的持久性的日志服务，它主要用于处理流式数据。具有横向扩展，容错，wicked fast(变态快)等优点，并已在成千上万家公司运行。
详细可查看官网：http://kafka.apache/
安装JDK
- JDK下载路径
- 按照网上参考步骤，依次配置JAVA_HOME、Classpath和Path，然后打开cmd，运行java -version成功，则JDK配置成功；
安装zookeeper
参考： Windows系统ZooKeeper集群环境搭建
安装Kafka
-
Kafka下载路径
-
下载步骤
(1) 请求Kafka下载路径
(2) 注意要下载二进制版本的, 点击下图圈红链接
(3) 点击点击下图圈红链接进行下载
-
下载后解压到任意一个目录，此处我解压的目录是：D:\ruanjian\kafka_2.13-2.5.0
-
修改配置文件
进入目录：D:\ruanjian\kafka_2.13-2.5.0\config，编辑文件"server.properties"
注意：配置文件中：zookeeper.connect=localhost:2181 是zookeeper的服务地址，请与上面已安装zookeeper服务的地址与端口保持一致。kafka会按照默认配置，在9092端口上运行，并连接zookeeper的默认端口2181。
-
启动Kafka服务
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
(4) 执行成功后日志如下图：
kafka演示
创建主题
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mumu
(4) 执行成功后日志如下图：
创建生产者
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic mumu
(4) 执行成功后日志如下图：
创建消费者
(1) 进入Kafka安装目录D:\ruanjian\kafka_2.13-2.5.0
(2) 按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
(3) 输入下面命令
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mumu
(4) 执行成功后日志如下图：
生产者发送消息，消费者消费消息
到此kafka安装成功！