我使用spark结构化流媒体从kafka读取数据并将数据写入kafka，由于某些问题，我需要使用foreach batch将数据写入kafka。
因此，为了处理与kafka的读写相关的代码异常，我计划使用异常处理。
就像这里提到的spark结构化流异常处理一样，我应该在foreach批处理函数中使用try catch块，还是可以直接在start（）方法的返回对象上使用它？
谢谢