Flume+kafka+SparkStreaming整合

1、需求 模拟一个流式处理场景:java 我再说话,我编写好的一个spark streaming作词频统计apache 1.模拟说话 : nc -lk 3399 flumebootstrap source :avro(qyl01:3399)app channel:memory框架 sink : kafkasinkoop 模拟实时的日志生成:ui echo aa bb cc >> /home/qyl
相关文章
相关标签/搜索