统一接口语义并移除 broker 的隐式全局副作用，降低调用方误用成本。同步文档与测试以保持配置覆盖和 s3_source 行为契约一致。