快手一道场景题目

拼接用户的点击和展现日志（先有展现日志，后有点击日志），点击日志存到kafka A，展现日志存到kafka B，现在要分别从这两个kafka里边取数据，根据展现id进行匹配，拼接成点展日志，最后写入kafka C，时间窗口是一小时（最多允许点击日志迟到一小时，否则就不再匹配）。

我的思路：
从kafka B读取展现日志，存入到map里，key是展现id，value是日志的内容，然后从kafka A里读取点击日志，和map的key进行匹配，如果匹配到进行拼接，匹配不到就意味着有点击日志但没有展现日志，说明超出了时间窗口，应该被丢弃。
有定时器判断map中的key是否超出一小时，如果超出则清除出map。

这个思路是否有问题？有没有更好的思路#牛客AI配图神器#
#面经#