我有一个streams应用程序，它计算传入交易的高/低/数量。我有一个包含交易信息的输入主题。没有与这些消息关联的时间戳。我从输入流创建一个kgroupedstream，并将其按股票符号作为键进行分组
然后我从kgroupedstream创建一个ktable。我聚合数据，计算高/低/卷，创建一个名为hilowmessage的新消息，并将其流输出到我的输出流。
因为输入主题总是有数据。如何确保只对今天的数据进行聚合，而不包括昨天的数据？注意，输入主题消息结构中没有时间戳。