关于多个来源，如何保证数据对齐

[steven chen]

hi:
    1.项目中我们会汇集不同来源的消息的，然和合并进行统计并输出结果。
   2. 有topic a 是所有的用户pv日志， topic b 
是所有用户uv日志，现在1个job同时消费a,b2个消息，并将pv,uv的结果同时输出到下一级的kafka topic c中，
问题：当a 消息 提前到达，b 消息晚20分钟到达，job 在工作时如何保证2个topic 数据对齐，或者说2边数据进行关联整合？
相当于2条消息处理后合并成1条往下游sink ,如何保证数据数据a和b对应的上？