4.3.1 Source 编写规范 在数据工程的浩瀚星图中,Source 不是起点,而是第一道校准刻度的基准线——它不生产数据,却定义数据是否“可信”;它不处理逻辑,却决定下游所有计算的语义边界。当你敲下 或 的那一刻,你签下的不是接口契约,而是一份数据主权声明:这份数据从哪里来、以何种形态存在、如何被感知、何时被确认、失败时向谁问责——全部凝结在 Source 的实现细节里。 这不是一个可以交给框架自动补全的模板方法。这是工程师与数据世界签订的第一份《日内瓦公约》:它必须精确到字节,严谨到时序,鲁棒到混沌。 我们直面现实:Flink 1.18+、Spark 3.5、Kafka 3.6、Pulsar 3.3、自研 CDC 引擎……这些运行环境早已不是教科书里的理想模型。