apache-flink - Flink 解决方案主动-主动多站点云数据摄取

我们有 Flink 作业使用来自 Kafka 的数据并将其摄取到多站点复制的 Cassandra。

现在我们必须每小时汇总一次数据。问题是设备 X 可以在站点 A 和站点 B 上报告一次。这意味着该设备的某些消息将由站点 A 中的 Flink 处理，而某些消息将在站点 B 处理。

我想要一个聚合结果，它将反映特定设备 X 传输的所有消息。

是否有处理多站点摄取的最佳实践？知道如何处理上述情况吗？提前致谢。

标签： apache-flinkflink-streaming