有没有办法将时间戳添加到 KSQL 流选择？

【问题标题】：Is there a way to add timestamp to KSQL stream select?有没有办法将时间戳添加到 KSQL 流选择？
【发布时间】：2018-11-03 13:08:08
【问题描述】：

我有一些使用 ksql 流的消息处理，我想为每个处理的行添加时间戳，以检索完成处理的时间。

最初我假设 ROWTIME 最终会得到更新，但它似乎是从最初的 Kafka 主题的消息中保留下来的。

TIMESTAMP 方法似乎用于将输入数据转换为特定的时间戳。

【问题讨论】：

【解决方案1】：

您可以编写一个新的 UDF 来获取时间戳并将其添加到结果中。有关如何为 KSQL 编写 UDF 的更多信息，请参阅以下页面：https://docs.confluent.io/current/ksql/docs/developer-guide/udf.html

【讨论】：