1

ksql ストリームを使用したメッセージ処理があり、処理が終了した時刻を取得するために、処理された各行にタイムスタンプを追加したいと考えています。

最初は ROWTIME が更新されると思っていましたが、最初の Kafka トピックのメッセージから保持されているようです。

TIMESTAMP メソッドは、入力データを特定のタイムスタンプに変換するために使用されているようです。

4

1 に答える 1