作者可以把me.jinkun.scala.util.InternalRedisClient下的代码分享一下嘛,里面的方法由于我水平有限,还原不了
SparkStreaming之写数据到Kafka本文主要记录使用SparkStreaming从Kafka里读取数据,并使用Redis保存Offset,并监听Redis中的某个Key是否存在来停止程序,将读取到的数据转换为j...
作者可以把me.jinkun.scala.util.InternalRedisClient下的代码分享一下嘛,里面的方法由于我水平有限,还原不了
SparkStreaming之写数据到Kafka本文主要记录使用SparkStreaming从Kafka里读取数据,并使用Redis保存Offset,并监听Redis中的某个Key是否存在来停止程序,将读取到的数据转换为j...