У меня проблемы с прохождением операции объединения.Похоже, поток данных останавливается после операции восстановления.Вот полный поток
Повторное сообщение (тема повторения Кафки) + Нормальное сообщение -> window keyBy -> сокращение -> процесс (используется для побочных выводов для сбора сообщений, не соответствующих критериям проверки, и последующей передачи их на повторную попыткуtopic)
Я провел некоторую отладку конвейера данных, и я почти уверен, что проблема вызвана введением операции объединения.Если я удаляю оператор объединения, все работает нормально.
Проблема в том, что я не вижу сообщений об ошибках в журналах.Кажется, что агрегированное сообщение просто потеряно, так как я мог видеть, что точка отладки функции сокращения была приостановлена.