提供創建流計算任務、實時消費數據的能力，縮短全鏈路數據流時延，平攤計算成本。支持不同場景下的高吞吐和低延遲，通過Exactly-once，At-least-once提升計算精準度。