这次的业务数据设计到 3 张表, 在 kafka 中有 3 个 topic. 在 Spark Streaming 中, 流的 join 是比较难处理的. 更好的解决方案是使用 Structured Streaming 处理流的 join.
所以这次的实时技术我们使用 Structured Streaming.