У меня есть два структурированных потоковых приложения Spark.Первый делает несколько оконных агрегатов и выводит их в Кафку в режиме «обновления».Второй читает этот поток Кафки, выполняет дальнейшую обработку и снова выводит данные в режиме «обновления».
Будет ли второе приложение, считывающее поток Кафки, считывать самые последние данные?