文件名称:kafka-storm:通过storm打印kafka消息的测试环境和代码
文件大小:11KB
文件格式:ZIP
更新时间:2024-06-30 01:02:11
Java
Storm和Kafka测试环境 这是一个简单的 vagrant 设置,用于在 3 个虚拟机上创建和配置 Storm 和 kafka。 kafka :192.168.111.100 上的 kafka vm、运行主管、zookeeper 和 kafka nimbus :192.168.111.101 上的storm numbus VM,运行supervisor、nimbus 和storm UI worker1 :storm worker VM,在 192.168.111.102 上运行受监督的主管 Storm-code 目录包含一个用于部署和测试的简单风暴拓扑。 有关该项目的更多详细信息... 用法 vagrant up 等待 ... 验证 worker 和 nimbus 已启动 vagrant ssh kafka cd 到 kafka 目录 bin/kafka-topics.sh
【文件预览】:
kafka-storm-master
----Vagrantfile(1KB)
----storm-code()
--------src()
--------pom.xml(2KB)
----README.md(1KB)
----provision()
--------supervisor-nimbus.conf(262B)
--------supervisor-ui.conf(250B)
--------supervisor-kafka.conf(321B)
--------kafka.sh(519B)
--------storm-worker.sh(437B)
--------storm.yaml(113B)
--------supervisor-worker.conf(274B)
--------storm-nimbus.sh(507B)
--------server.properties(5KB)
--------supervisor-zk.conf(256B)
----.gitignore(140B)