Windows本机搭建kafka+storm环境

一、启动ZK

从c到d盘
cd D:stormzookeeper-3.3.6bin
zkServer.cmd

可见，

二、搭建Storm

cd D:stormstorm-0.9.1-incubating-SNAPSHOT-12182013storm-0.9.1-incubating-SNAPSHOT-12182013bin

这里这个可以写在环境变量里面
计算机–>属性–>高级系统设置–>高级–>环境变量
新增系统变量
STORM_HOME= D:stormstorm-0.9.1-incubating-SNAPSHOT-12182013storm-0.9.1-incubating-SNAPSHOT-12182013bin

这样可以：

1）storm nimbus

zk窗口可见，

2）storm supervisor
又开了一个窗口，可见，

zk窗口可见，

3）启动UI
storm ui
又新开一个窗口，显示

可打开UI
http://localhost:8080/
视情况，可执行：
在PATH中加入如下内容：(python路径视个人安装目录而定)

;%STORM_HOME%bin;%JAVA_HOME%bin;E:Python27;C:Python27Libsite-packages;
在PATHEXT中加入   .PY

三、搭建Kafka

从官网下载二进制版本解压后即安装完了下载稳定版本kafka_2.10-0.8.2.1
修改一下地方：
config里面
1、修改log4j.properties的”kafka.logs.dir=logs”为”kafka.logs.dir=/tmp/logs”
2、修改test-log4j.properties 的四处”File=logs/server.log”为”File=/tmp/logs/server.log”
3、复制server.properties为第一个节点server-9093.properties，修改如下内容：
broker.id=9093
port=9093
host.name=localhost
log.dirs=/tmp/kafka-logs-9093

第二个节点server-9094.properties，修改如下内容：
broker.id=9094
port=9094
host.name=localhost
log.dirs=/tmp/kafka-logs-9094

我在windows目录，

回显，

再启另一个，回显

下面试试创建topic，

查看刚刚创建的top信息

模拟生产消息

模拟消费消息，另启一窗口

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/gohigher2018/article/details/80383231
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

发表于 2021-06-14 05:04:58
阅读 ( 1367 )
分类：Go环境配置