Отставание по теме Kafka при использовании структурированной потоковой передачи Spark
Можно ли как-то выяснить отставание по теме kafka при использовании структурированной потоковой передачи?
Я проверил streamQuery.lastprogress и streamQuery.status, ни одно из них не содержит таких значений.
Хотите узнать, есть ли способ узнать.