Hello. I am trying to test the processing delay introduced by KSQLDB and I need the processing timestamp to do this. As I understand ROWTIME is the timestamp of the kafka record. Is there a way to insert a processing timestamp in a stream?
Hello. I am trying to test the processing delay introduced by KSQLDB and I need the processing timestamp to do this. As I understand ROWTIME is the timestamp of the kafka record. Is there a way to insert a processing timestamp in a stream?