文件名称:log-analysis-kafka-storm-docker:在Docker中运行的Kafka,Storm,Zookeeper和Openfire
文件大小:25KB
文件格式:ZIP
更新时间:2024-05-27 00:46:53
Java
本文主要目的在于将Storm运行环境集成到docker容器中,在一个快速开发模式下运行测试。代码内容来自 第四章。 本代码仅供学习。这个样例程序主要是分析日志文件,一旦符合某个threshold,将通过XMPP告警。 - 将日志信息写到Apache Kafka; - Storm流处理streaming功能负责分析日志; - 实现移动平均线式的分析; - Storm将告警信息使用XMPP协议通知给管理员。 ##下载源码 git clone kafka-log-appender:将日志内容写到kafka程序 log-kafka-storm:docker-compose脚本和storm程序 ##准备docker环境 ###启动docker docker-compose环境搭建过程请查看我的 进入log-kafka-storm目录,查看docker-compose.yml文件,假设我
【文件预览】:
log-analysis-kafka-storm-docker-master
----README.md(12KB)
----kafka-log-appender()
--------src()
--------pom.xml(2KB)
----log-kafka-storm()
--------start-kafka-shell.sh(100B)
--------src()
--------docker-compose.yml(831B)
--------pom.xml(4KB)