Flume+Kafka+SparkStreaming+Redis+Mysql做的实时日志分析ip访问次数

新手学习，如有错误请指正，感谢！ 1.启动zookeeper和kafka，并建立一个topic为test-fkss，为了方便观察我是通过kafka-manager添加 2.配置Flume并启动，监听文件为/home/czh/docker-public-file/testflume.log，发送给kafka a1.sources = r1 a1.sinks = k1 a1.channels = c1

>>阅读原文<<