Windows安装运行Kafka
简介
本文讲述了如何在Windows OS上配置并启动Apache Kafka，这篇指南将会指导你安装Java和Apache Zookeeper。
Apache Kafka是一个快速可扩展的消息队列，能够应对繁重的读写负载，即IO相关工作。关于在Windows安装Kafka的具体步骤，可以查看这个视频：
s://youtu.be/OJKesEpO6ok
下载所需文件
针对此教程，我们将Zookeeper与Kafka解压到C盘，不过也可以选择其
他位置。这里我们要使用完全的zookeeper，而不是用Kafka打包的那
个，因为这是一个单节点的Zookeeper实例。也可以运行打包了
zookeeper的Kafka，位置在\kafka\bin\windows库中。
安装
A. JDK安装
1.启动JRE安装，选中复选框“修改目标路径”，然后点击安装。
2.修改安装目录，文件夹名称中不能有空格，例如：
C:\Java\jre1.8.0_xx\〔默认情况下是C:\Program
Files\Java\jre1.8.0_xx〕，然后点击下一步。
3.现在点击控制面板->系统->高级系统设置->环境变量，打开系统环境变量对话框。
4.点击用户变量中的新用户变量按钮，然后在变量名称那里输入
JAVA_HOME，并将自定义的jre路径填入变量值。如以下图所示：
Java路径与版本可能会根据所使用Kafka的版本而有所改变
5.现在点击ok。
6.刚刚打开的“环境变量“对话框中有“系统变量”一栏，在其中寻路径变量。
7.编辑路径与类型“;%JAVA_HOME%\bin”，如以下图：<；喎
�"/kf/ware/vc/" target="_blank"
class="keylink">vcD4NCjxwPjxpbWcgYWx0PQ=="图片描述"
src="/uploadfile/Collfiles/20160219/2016021909165796.png"
title="\" />
8.确认Java安装打开cmd，输入类型“java –version”，应该能够看到刚刚安装的java版本。
如果命令行提示与上图类似，请继续。否则，需要重新检查安装版本是否与OS架构匹配〔x86, x64〕，以及环境变量路径是否正确。
B. Zookeeper安装
1.进入Zookeeper设置目录，比方C:\zookeeper-3.4.7\conf
2. 将“zoo_sample.cfg”重命名为“zoo.cfg”。
3. 在任意文本编辑器〔如notepad〕中打开zoo.cfg，我个人更喜欢notepad++。
4. 到并编辑dataDir=/tmp/zookeeper to :\zookeeper-3.4.7\data
5. 与Java中的做法类似，我们在系统环境变量中添加：
a. 在系统变量中添加ZOOKEEPER_HOME = C:\zookeeper-3.4.7
b. 编辑系统变量，命名为路径 System
Variable%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg文件中修改默认的Zookeeper端口〔默认端口2181〕。
7. 打开新的cmd，输入zkserver，运行Zookeeper。
8. 命令行提示如下：
恭喜，Zookeeper已经完成并在端口2181运行。
C. 安装Kafka下载apache
1. 进入Kafka配置目录，例如C:\kafka_
2.11-0.9.0.0\config
2. 编辑文件“server.properties”
3. 到并编辑“log.dirs=/tmp/kafka-logs” to “log.dir=
C:\kafka_2.11-0.9.0.0\kafka-logs”
4. 如果Zookeeper在某些其他的机器或集上运行，可以将“t:2181”修改为自定义IP与端口。在这个演示中我们使用了同一个机器，因此没必要做修改。文件中的Kafka端口和
broker.id也是可以配置的。其他设置不变。
5. Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181。
D. 运行Kafka服务器
重要：请确保在启动Kafka服务器前，Zookeeper实例已经准备好并开始
运行。
1.进入Kafka安装目录C:\kafka_
2.11-0.9.0.0\
2.按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.现在输入.\bin\windows\kafka-server-
start.bat .\config\server.properties 并回车。
.\bin\windows\kafka-server-
start.bat .\config\server.properties
4.如果一切正常，命令行应当是这样：
5.现在Kafka已经准备好并开始运行，可以创建主题来存储消息了。我们
也能从Java/Scala代码中，或直接从命令行中生成或使用数据。
E. 创建主题
1. 现在创建主题，命名为“test”，replication factor=1〔因为只有1个Kafka服务器在运行〕。如果集中所运行的Kafka服务器不止1个，
可以相应增加replication-factor，从而提高数据可用性和系统容错性。
2. 在C:\kafka_2.11-0.9.0.0\bin\windows打开新的命令行。
3. 输入下面的命令，回车：
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。