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

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

>>阅读原文<<