У меня есть обработка сообщений с использованием потоков ksql, и я хотел бы добавить метку времени к каждой обработанной строке, чтобы получить время завершения обработки.
Первоначально я предполагал, что ROWTIME в конечном итоге будет обновляться, но кажется, что он сохраняется из исходного сообщения темы Kafka.
Методы TIMESTAMP, похоже, используются для преобразования входных данных в какую-то конкретную временную метку.
