我正在使用的数据来自 kafka 与 createDirectStream() 应用程序编程接口。我想
catch ClosedChannelException 并处理断开连接到 zookeeper Kafka的主题。
通过测试，我只能做到：

try { myStreamingContext.awaitTermination }
catch { case foo:SparkException => if (foo.getMessage contains """ClosedChannelException""") /*do something*/ }

似乎只有在上述情况下例外才是“可捕捉的”，或者至少在以下情况下是不可捕捉的 try { val stream = createDirectStream([...]) } [...] 如我所料。
有什么方法可以处理这个（和其他连接错误）应用程序端吗？