Kafka安裝http://blog.csdn.net/aitcax/article/details/49583351
Git地址http://git.oschina.net/catshen/zsWing
增加兩個(gè)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
以項(xiàng)目的cms模塊為例（配置topic和kafka地址）
配置自定義日志級(jí)別
添加日志
Blog模塊
啟動(dòng)storm
啟動(dòng)web
導(dǎo)入最新的sql
通過刪除一條文章產(chǎn)生日志到kafka
Qq群483681368
