spark streaming从kafka读取消息,offset写入Redis,spark计算单词出现频率,最后写入hive表

使用Springboot框架,Sparkstreaming监听Kafka消息,Redis记录已读Kafka偏移量,Spark统计单词出现次数,最后写入Hive表