作者可以把me.jinkun.scala.util.InternalRedisClient下的代碼分享一下嘛强窖,里面的方法由于我水平有限,還原不了
SparkStreaming之寫數(shù)據(jù)到Kafka本文主要記錄使用SparkStreaming從Kafka里讀取數(shù)據(jù)滓鸠,并使用Redis保存Offset拾碌,并監(jiān)聽Redis中的某個(gè)Key是否存在來(lái)停止程序吐葱,將讀取到的數(shù)據(jù)轉(zhuǎn)換為j...
作者可以把me.jinkun.scala.util.InternalRedisClient下的代碼分享一下嘛强窖,里面的方法由于我水平有限,還原不了
SparkStreaming之寫數(shù)據(jù)到Kafka本文主要記錄使用SparkStreaming從Kafka里讀取數(shù)據(jù)滓鸠,并使用Redis保存Offset拾碌,并監(jiān)聽Redis中的某個(gè)Key是否存在來(lái)停止程序吐葱,將讀取到的數(shù)據(jù)轉(zhuǎn)換為j...