我有一些使用 ksql 流的消息处理，我想为每个处理的行添加时间戳，以检索完成处理的时间。
最初我假设 ROWTIME 最终会得到更新，但它似乎是从最初的 Kafka 主题的消息中保留下来的。
TIMESTAMP 方法似乎用于将输入数据转换为某些特定的时间戳。
1 回答
1
您可以编写一个新的 UDF 来获取时间戳并将其添加到结果中。有关如何为 KSQL 编写 UDF 的更多信息，请参阅以下页面：https ://docs.confluent.io/current/ksql/docs/developer-guide/udf.html
于 2018-11-01T05:11:21.057 回答