快手一道场景题目

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

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

这个思路是否有问题?有没有更好的思路#牛客AI配图神器#
#面经#
全部评论
啥部门
点赞 回复 分享
发布于 04-08 14:58 上海

相关推荐

评论
点赞
1
分享

创作者周榜

更多
牛客网
牛客企业服务