SparkStreaming Join问题

Question

sparkStreaming程序中有两个数据源分别来自两个不同的topic，两个topic中通过id进行join。但是数据可能存在不在同一个 batch的现象，第二个topic比第一个的数来的早点 或者晚点 或者压根不一块来，应该怎么解决。

Answer 1

用redis缓存，将第一个topic中没有匹配到的数据存到redis，然后每个batch去读redis，如果匹配到就将该条数据删掉。