Flink非常适合处理来自Kafka主题(或任何其他数据源)的历史数据,因为它支持事件时间处理,即基于记录中的时间戳的基于时间的处理,而不是基于处理机器的时钟(又名处理时间)。
如果您只想执行分析,可能需要查看Flink的SQL支持。