美文网首页
kafka跟storm收集日志解决方案

kafka跟storm收集日志解决方案

作者: zscat | 来源:发表于2017-05-08 14:15 被阅读85次

Kafka安装http://blog.csdn.net/aitcax/article/details/49583351

Git地址http://git.oschina.net/catshen/zsWing

增加两个topic

bin/kafka-topics.sh --create --zookeeper 10.2.10.61:2181 --replication-factor 1 --partitions 1 --topic blog

bin/kafka-topics.sh --create --zookeeper 10.2.10.61:2181 --replication-factor 1 --partitions 1 --topic cms

通过log4j2添加日志到kafka

以项目的cms模块为例(配置topic和kafka地址)

配置自定义日志级别

添加日志

Blog模块

启动storm

启动web

导入最新的sql

通过删除一条文章产生日志到kafka

Qq群483681368

相关文章

网友评论

      本文标题:kafka跟storm收集日志解决方案

      本文链接:https://www.haomeiwen.com/subject/uvbmtxtx.html