Spark讀取Kafka由於序列化引發的問題:org.apache.spark.sql.streaming.StreamingQueryException: null

背景 從kafka讀取數據而後寫入到kafka，可是報錯，公司的插件化開發，這裏手寫代碼復現一下這個錯誤java @Test def kafkaToKafkaTest(): Unit ={ val spark = SparkSession.builder.appName("JavaStructuredKafka").master("local[4]").enableHiveSuppor

>>阅读原文<<