有没有一种简单的方法在Windows上安装Kafka？

Question

我正在尝试在Windows上安装Kafka消息队列以进行测试(不适用于生产:D).

我只发现了这篇关于如何在Windows上安装Apache Kafka 0.8的文章:http://janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/

这很酷但是:

1. 它已经过时了
2. 这太复杂了......

有人知道一个简单的方法来实现这一目标吗？

谢谢.

Answer 1

好吧,它最终并不复杂:)

唯一的步骤是:

1. 下载Kafka并将其解压缩到好处(让我们说C:/Kafka)
2. 安装Cygwin

3. 编辑\bin\kafka-run-class.sh并在文件末尾进行更改

   exec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "$@"

   至

   exec java $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp `cygpath -wp $CLASSPATH` $KAFKA_OPTS "$@"

4. 在Environment Variables中,将java添加到Path系统变量:

   

就是这样..你现在可以运行ZooKeeper和Kafka服务器并开始玩主题和东西 ..

Answer 2

一个更新的答案为其他人的利益仍然想知道这一点,我下载了二进制文件,一切都开箱即用.但是,源版本不起作用.

Answer 3

这些是我在Windows上运行kafka时所遵循的步骤

1. 首先安装Zookeeper(我下载了 v3.3.6)zookeeper-3.3.6.tar.gz
2. 解压缩Zookeeper并在powershell/cmd中运行此命令\zookeeper-3.3.6\bin> .\zkServer.cmd现在这应该是一个Zookeeper实例localhost:2181
3. 下载Kafka二进制版(我下载了 v0.10.0.1)kafka_2.10-0.10.0.1.tgz
4. 提取卡夫卡,时间来修改一些配置
5. 在卡夫卡提取内你可以找到 .\config\server.properties
6. 在.\config\server.properties替换log.dirs=c:/kafka/kafka-logs
7. 注意:确保在相关路径中创建这些文件夹
8. 新闻:现在Kafka附带windows .bat脚本,您可以在./bin/windows文件夹中找到这些文件
9. 启动powershell/cmd并运行此命令以启动Kafka代理 .\bin\windows\kafka-server-start.bat .\config\server.properties
10. DONE!,现在您有一个正在运行的Zookeeper实例和一个Kafka代理.

Answer 4

您可能会发现Kafka在bin文件夹下附带了Windows .bat文件,以帮助您在Windows下运行Kafka.但是,自0.8.0版本以来,这些bat文件没有更新,并且Kafka的一些逻辑已经改变(关于主题等).

我试过两种方法来解决这个问题.一种是使用Cygwin或MinGW来模拟Linux环境并运行Linux shell脚本,但是会有大量与路径名相关的其他问题.另一个更简单且更少麻烦的解决方案是使用更正版本的Windows bat文件.

请参阅此博客文章.

Answer 5

1. 从https://kafka.apache.org/downloads下载Kafka的任何二进制版本（我已经下载了kafka_2.11-0.10.2.0）
2. 将其解压缩到任何文件夹（我解压缩到“ C：\ Kafka”）
3. 打开命令提示符
4. 转到解压缩Kafka的文件夹（C：\ Kafka \ kafka_2.11-0.10.2.0）
5. 运行此命令。\ bin \ windows \ zookeeper-server-start.bat。\ config \ zookeeper.properties以启动Zookeeper
6. 运行此命令。\ bin \ windows \ kafka-server-start.bat。\ config \ server.properties以启动Kafka

现在可以了！