在Windows上安装Kafka有没有简单的方法?

我试图在Windows上安装Kafka消息队列以进行testing (不适用于生产:D)。

我只find这篇文章,介绍如何在Windows上安装Apache Kafka 0.8: http : //janschulte.wordpress.com/2013/10/13/apache-kafka-0-8-on-windows/

这很酷,但:

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

有人知道一个简单的方法来实现呢?

谢谢。

好吧,这终于不复杂:)

唯一的步骤是:

  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. 环境变量中 ,将java添加到路径系统变量中:

    在这里输入图像说明

就是这样..你现在可以运行ZooKeeper和Kafka服务器,并开始播放主题和内容 。

对于其他任何人仍然想知道这个问题的更好的答案,我下载了这个二进制文件,所有的东西都是开箱即用的。 源版本,但是,没有工作。

您可能会发现,Kafka带有bin文件夹下的Windows .bat文件,以帮助您在Windows下运行Kafka。 然而,这些bat文件从版本0.8.0开始并没有更新,卡夫卡的一些逻辑已经改变了(关于主题等)。

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

请参阅这篇博文 。

这些是我在Windows上运行kafka的步骤

  1. 首先安装Zookeeper(我下载了 v3.3.6) zookeeper-3.3.6.tar.gz
  2. 解压Zookeeper并在powershell / cmd \zookeeper-3.3.6\bin> .\zkserver.cmd运行这个命令现在,这应该在localhost:2181上的一个Zookeeper实例
  3. 下载Kafka二进制版本(我下载了 v0.10.0.1) kafka_2.10-0.10.0.1.tgz
  4. 提取Kafka,有时间修改一些配置
  5. 在Kafka提取内部,您可以找到.\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. 完成!,现在你有一个正在运行的Zookeeper实例和一个Kafka经纪人。

步骤如下 –

  1. 应该设置Java环境变量。
  2. 到达Apache Kafka下载页面并下载Scala 2.12 kafka_2.12-0.10.2.1.tgz
  3. 解压缩。
  4. 打开cmd提示符并启动zookeeper-

    C:\ kafka_2.12-0.10.2.1> \ bin \ windows \ zookeeper-server-start.bat。\ config \ zookeeper.properties

  5. 打开一个新的命令提示符并启动Apache Kafka-

    C:\ kafka_2.12-0.10.2.1>。\ bin \ windows \ kafka-server-start.bat。\ config \ server.properties

  6. 打开一个新的命令提示符并创建一个名为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

  7. 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

  8. 最后打开一个新的命令提示符并启动用户,该用户监听上面刚创建的主题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

  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

现在它工作!