在Kafka星团，假设我有一个 arrived_now 包含当前所有到达数据的主题。例如，我想创建一个包含最多24小时前的所有数据的主题 arrived_24hrs_ago .
我指的是比给定时间更老的记录。
当我在10秒之前查找记录时，这个查询可以工作，但是在更长的时间内（比如一小时或一天）它没有返回任何值。

SELECT * FROM ARRIVED_NOW_STREAM WHERE ROWTIME < UNIX_TIMESTAMP()-(10*1000) EMIT CHANGES;

任何线索都将不胜感激。