我的Kafka主题包含带有id字段的消息 . 我希望使用时间窗口按该id聚合消息，当副本进入时，应该移动该时间窗口 .
例：
我用 id = 94 检索了一条消息 . 我想等待 id = 94 的下一条消息30秒，如果它赢了't appear, I' m将开始处理 . 但是如果在这30秒内收到带有 id = 94 的新消息，我想重置定时器并等待下一个 id = 94 30秒 .
id = 94
是否可以使用Kafka Streams或类似技术实现此类逻辑？
谢谢 .