首先配置flume文件的信息(flume2kafka.properties)# flume-kafka.properties: 用来定制agent的各个组件的行为（source,channel,sink）############################################# 对各个组件的描述说明# 其中a1为agent的名字# r1是a1的source的代号名字# ...

每五秒计算一次mini1:8888（mini1是虚拟机ip映射名称）收到的数据可以用nc命令模拟产生数据：在mini1上执行nc -lk 8888import org.apache.spark.streaming.{Seconds, StreamingContext}import org.apache.spark.{SparkConf, SparkContext}object St...