我有一些使用ksql流的消息处理，我想为每个处理的行添加时间戳，以便检索完成处理的时间。起初，我假设rowtime最终会得到更新，但它似乎会从最初kafka主题的消息中保留下来。时间戳方法似乎用于将输入数据转换为特定的时间戳。
roqulrg31#
您可以编写一个新的udf来获取时间戳并将其添加到结果中。有关如何为ksql编写自定义项的更多信息，请参阅以下页面：https://docs.confluent.io/current/ksql/docs/developer-guide/udf.html
1条答案
按热度按时间roqulrg31#
您可以编写一个新的udf来获取时间戳并将其添加到结果中。有关如何为ksql编写自定义项的更多信息，请参阅以下页面：https://docs.confluent.io/current/ksql/docs/developer-guide/udf.html