我试图在Windows上安装Kafka消息队列以进行testing (不适用于生产:D)。
我只find这篇文章,介绍如何在Windows上安装Apache Kafka 0.8: http : //janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/
这很酷,但:
有人知道一个简单的方法来实现呢?
谢谢。
好吧,这终于不复杂:)
唯一的步骤是:
编辑\ 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 "$@"
在环境变量中 ,将java添加到路径系统变量中:
就是这样..你现在可以运行ZooKeeper和Kafka服务器,并开始播放主题和内容 。
对于其他任何人仍然想知道这个问题的更好的答案,我下载了这个二进制文件,所有的东西都是开箱即用的。 源版本,但是,没有工作。
您可能会发现,Kafka带有bin文件夹下的Windows .bat文件,以帮助您在Windows下运行Kafka。 然而,这些bat文件从版本0.8.0开始并没有更新,卡夫卡的一些逻辑已经改变了(关于主题等)。
我已经尝试了两种方法来解决这个问题。 一种是使用Cygwin或MinGW来模拟Linux环境并运行Linux shell脚本,但是会有很多与路径名相关的其他问题。 另一个解决方案,更简单,麻烦更少,就是使用Windows bat文件的正确版本。
请参阅这篇博文 。
这些是我在Windows上运行kafka的步骤
zookeeper-3.3.6.tar.gz
\zookeeper-3.3.6\bin> .\zkserver.cmd
运行这个命令现在,这应该在localhost:2181
上的一个Zookeeper实例 kafka_2.10-0.10.0.1.tgz
.\config\server.properties
.\config\server.properties
替换log.dirs=c:/kafka/kafka-logs
./bin/windows
文件夹中找到这些文件 .\bin\windows\kafka-server-start.bat .\config\server.properties
步骤如下 –
打开cmd提示符并启动zookeeper-
C:\ kafka_2.12-0.10.2.1> \ bin \ windows \ zookeeper-server-start.bat。\ config \ zookeeper.properties
打开一个新的命令提示符并启动Apache Kafka-
C:\ kafka_2.12-0.10.2.1>。\ bin \ windows \ kafka-server-start.bat。\ config \ server.properties
打开一个新的命令提示符并创建一个名为javainuse-topic的主题,该主题只有一个分区和一个副本。
C:\ kafka_2.12-0.10.2.1>。\ bin \ windows \ kafka-topics.bat –create –zookeeper localhost:2181 – 复制因子1 –partition 1 – topic javainuse-topic
Next打开一个新的命令提示符,并创建一个生产者发送消息到上面创建的javainuse-topic并发送一条消息 – Hello World Javainuse给它 –
C:\ kafka_2.12-0.10.2.1>。\ bin \ windows \ kafka-console-producer.bat –broker-list localhost:9092 – topic javainuse-topic
Hello World Javainuse
最后打开一个新的命令提示符并启动用户,该用户监听上面刚创建的主题javainuse-topic。 我们会收到我们使用制作人发送的信息
C:\ kafka_2.12-0.10.2.1>。\ bin \ windows \ kafka-console-consumer.bat –bootstrap-server localhost:9092 –topic javainuse-topic –from-beginning
包括屏幕截图和视频在内的详细步骤可以在这个博客中找到 – Apache Kafka入门
在0.9.0版本中。 窗口的“bin”文件夹中有脚本。 你可以使用它们。
你也可以使用Chocolatey: https : //chocolatey.org/packages/kafka
我还没有尝试过。
是的,我在Windows机器上配置了ZOOKEEPER和Apache Kafka。 对于ZOOKEEPER,只需配置ZOOKEEPER_HOME并设置路径,然后将zoo.sample.cfg重命名为zoo.cfg,并更改zoo.cfg中dataDir的路径
对于Apache Kafka,只需解压并从bin文件夹中启动服务器,然后从Kafka目录下的windows文件夹启动Producer / Consumer
现在它工作!