kafka和flume集成

使用flume+kafka+sparkstreaming进行日志实时处理,flume做为kafka的producer,sparkstreaming做为kafka的消费者。shell flume只有1.6.0和以上的版才能够和kafka集成,1.6.0以前的版本没有提供kafka sink这个功能,在kafka中建立一个flumeTopic topic,而后使用flume 监控五个日志文件,五个文件
相关文章
相关标签/搜索