流式处理选型：Flink与Spark Structured Streaming

流式处理选型：Flink与Spark Structured Streaming概览流处理关注低延迟与状态一致性。Flink 与 Spark S.S. 分别以连续与微批模型提供不同的权衡。技术参数（已验证）执行：Flink 连续流，Spark S.S. 微批；二者均支持事件时间与水位线（watermark）。一致性：通过检查点与两阶段提交实现恰好一次（exactly-once）语义（端到端需下游支持）。状态：本地状态与算子状态管理需结合容错与回放策略。实战清单依据延迟与生态选择方案，日志/实时指标偏向 Flink，批流一体偏向 Spark。统一事件时间与水位线策略，避免乱序导致窗口计算偏差。