Я запускаю запрос на структурированную потоковую передачу в формате Spark следующим образом:
val strquery = tempDataFrame2.writeStream.outputMode("append").queryName("table").format("console").start()
Но я не знаю, какие другие параметры использовать в этом выражении, чтобы программа Spark знала, что нет записей kafka для использования инемедленно прекратить потоковую передачу?