Subscribe[String,String](Array(kafkaTopics),kafkaParam)) val valueDStream: DStream[String] = inputDStream.map(_.value()) valueDStream.
確定! 回上一頁