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

>>阅读原文<<