就这个 https://blog.csdn.net/qq_44630724/article/details/110789285 spark实战小项目遇到一点问题

问题遇到的现象和发生背景

问题相关代码，请勿粘贴截图

val kafkaDStream = KafkaUtils.createDirectStreamString,String,StringDecoder,StringDecoder

Exception in thread "main" org.apache.spark.SparkException: java.nio.channels.ClosedChannelException

运行结果及报错内容

我的解答思路和尝试过的方法

我想要达到的结果