我想編譯併爲給定鏈接中的spark本身提供的Spark kinesis流scala應用程序創建一個jar。 Kinesis word count sample 以下是我的sbt文件,它具有所有的依賴關係,並且它適用於簡單程序的編譯。 name := "stream parser"
version := "1.0"
val sparkVersion = "2.0.2"
libraryDe
我已經寫下面的代碼來連接火花流的kinesis,但沒有收到數據。 VAL kinesisStream = KinesisUtils.createStream(SSC,APPNAME,streamName中,endpointUrl,regionName,InitialPositionInStream.LATEST,batchInterval,StorageLevel.MEMORY_AND_DISK_