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