Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和 Java 编写。该项目的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。其持久化层本质上是一个“按照分布式事务日志架构的大规模发布/订阅消息队列”，这使它作为企业级基础设施来处理流式数据非常有价值。
Windows 安装
由于 Kafka 依赖于 ookeeper 所以我们先安装 Zookeeper
安装 Zookeeper
下载地址
解压并复制到工作目录
我们在这里安装最新的 apache-zookeeper-3.5.5.tar.gz。
复制到工作目录，例如：D:\apache-zookeeper-3.5.5
修改配置参数
进到 D:\apache-zookeeper-3.5.5\conf， 复制 zoo_sample.cfg 并重命名为 zoo.cfg
编辑 zoo.cfg，修改 dataDir 为：
dataDir=/apache-zookeeper-3.5.5/data
添加环境变量
ZOOKEEPER_HOME D:\apache-zookeeper-3.5.5
path %ZOOKEEPER_HOME%\bin
打开terminal，尝试运行：
$ zkserver
…没有java环境变量？
我这里提示
Error: JAVA_HOME is not set.
添加一下JAVA_HOME环境变量
又出错了。。。
Error: Could not find or load main class org.apache.zookeeper.server.quorum.QuorumPeerMain
中文是
错误: 找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain
$ zookeeper-server-start.bat ../../config/zookeeper.properties
$ kafka-server-start.bat ../../config/server.properties
.\bin\windows\kafka-server-start.bat .\config\server.properties
.\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo
.\kafka-console-producer.bat --broker-list localhost:9092 --topic testDemo
.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testDemo
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
