快手一道场景题目
拼接用户的点击和展现日志(先有展现日志,后有点击日志),点击日志存到kafka A,展现日志存到kafka B,现在要分别从这两个kafka里边取数据,根据展现id进行匹配,拼接成点展日志,最后写入kafka C,时间窗口是一小时(最多允许点击日志迟到一小时,否则就不再匹配)。
我的思路:
从kafka B读取展现日志,存入到map里,key是展现id,value是日志的内容,然后从kafka A里读取点击日志,和map的key进行匹配,如果匹配到进行拼接,匹配不到就意味着有点击日志但没有展现日志,说明超出了时间窗口,应该被丢弃。
有定时器判断map中的key是否超出一小时,如果超出则清除出map。
这个思路是否有问题?有没有更好的思路#牛客AI配图神器#
#面经#
我的思路:
从kafka B读取展现日志,存入到map里,key是展现id,value是日志的内容,然后从kafka A里读取点击日志,和map的key进行匹配,如果匹配到进行拼接,匹配不到就意味着有点击日志但没有展现日志,说明超出了时间窗口,应该被丢弃。
有定时器判断map中的key是否超出一小时,如果超出则清除出map。
这个思路是否有问题?有没有更好的思路#牛客AI配图神器#
#面经#
全部评论

啥部门
相关推荐
点赞 评论 收藏
分享
点赞 评论 收藏
分享
点赞 评论 收藏
分享