1. 程式人生 > >kafka跟storm收集日誌解決方案

kafka跟storm收集日誌解決方案

增加兩個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