package com.scala.sparkStreaming
import org.apache.spark.streaming._
at org.apache.spark.streaming.StreamingContext.validate(StreamingContext.scala:517)
at org.apache.spark.st
没有得到任何错误或异常,但我没有看到信息在控制台以及输出卡夫卡主题。谁能让我知道我在哪里/我错过了什么? val logger: Logger = LoggerFactory.getLogger(Test.getClass)
valIf it's required to delete it under any circumstances, please set spark.sql.streaming.forceDe