Apache Flink Agents：一項里程碑式合作，旨在構建可擴展、面向生產的事件驅動型流式智能體框架。

作者：宋辛童，Apache Flink PMC Member，阿里雲高級技術專家 

在 Flink Forward Barcelona 2025 大會上，我們宣佈：阿里雲、Ververica、Confluent 與 LinkedIn 四家數據流領域的領軍企業正式攜手，共同推進 Apache Flink Agents 的開發與共建 —— 這是 Apache Flink 社區推出的全新開源子項目，致力於將 AI 智能體（Agents）引入實時、事件驅動的系統世界。這一倡議標誌着工業級 AI 應用邁出了關鍵一步：能夠對實時數據流做出即時且自主的響應。

為何 Apache Flink Agents 至關重要？

儘管 AI 智能體在聊天機器人等交互式應用中已取得顯著進展，但大多數仍運行在高吞吐、低延遲的實時數據處理體系之外。然而，在電商、金融、物聯網和物流等工業場景中，關鍵決策必須基於實時事件迅速作出——例如支付失敗、傳感器異常或用户點擊。這類工作負載不僅需要“智能”，更要求具備大規模處理能力、毫秒級延遲、容錯機制和有狀態協調能力，而這正是 Apache Flink 的核心優勢。然而此前，業界一直缺乏一個統一框架，將智能體 AI 模式融入這一成熟的流處理生態。Apache Flink Agents 正是為了填補這一空白而生。

什麼是 Apache Flink Agents？

Apache Flink Agents 是 Apache Flink 社區推出的全新開源子項目，是一個用於構建事件驅動型智能體的框架。它基於 Flink 經過大規模生產驗證的流式引擎，繼承了其分佈式、可擴展、容錯的結構化數據處理能力以及成熟的有狀態管理機制，並在此基礎上，為智能體 AI 的核心構建模塊與功能——如大語言模型（LLMs）、提示詞（prompts）、工具調用、記憶機制、動態編排、可觀測性等——引入了原生支持與抽象。

該項目是由阿里雲牽頭、聯合 Ververica、Confluent 和 LinkedIn 的開發者推動的，團隊成員在大規模流處理與實時 AI 系統方面擁有深厚的技術積累。通過整合我們在生產級數據基礎設施與智能系統方面的經驗，我們正朝着一個共同願景邁進：將智能體 AI 融入流式數據生態系統，使其具備可擴展性、高可靠性與真正的實時響應能力。

Apache Flink Agents 主要特性包括：

• 大規模數據處理與毫秒級時延：依託 Flink 的分佈式處理引擎，實時處理海量事件流。
• 數據與 AI 的無縫集成：直接將 Flink 的 DataStream 和 Table API 作為智能體的輸入和輸出，實現 Flink 中結構化數據處理與 AI 文本處理能力的平滑集成。
• Action 級別的精確一次一致性：通過將 Flink 的檢查點機制與外部預寫日誌相結合，確保智能體的 Action 及其外部效應具備精確一次一致性語義。
• 熟悉的智能體抽象：沿用業內常見的 AI 智能體概念，便於具有相關經驗的開發者快速上手並在 Apache Flink Agents 上構建應用。
• 多語言支持：同時提供原生的 Python 與 Java API，適配多樣化開發環境，支持團隊選擇偏好的編程語言。
• 豐富的生態系統：原生集成主流大語言模型（LLM）、來自不同提供商的向量存儲，以及託管在 MCP 服務器上的工具與提示詞，並支持自定義擴展。
• 可觀測性：採用以事件為中心的編排方式，所有智能體的 Action 均由事件連接與控制，可通過事件日誌觀察並理解智能體行為。

未來展望
Apache Flink Agents 首個公開版本 0.1.0 將於 10 月發佈。該版本將包含核心智能體抽象、Flink DataStream 與 Table API 集成、基於 Kafka 的行動一致性保障、主流 LLM 與向量庫支持、MCP 集成，以及基於事件日誌的可觀測能力。

這一里程碑標誌着在 Apache Flink 上構建可擴展、事件驅動型 AI 智能體的新時代正式開啓。欲瞭解更多信息，請訪問 Apache Flink GitHub 倉庫。

詳細路線圖、設計討論與社區反饋，請參見GitHub Discussions 頁面——在這裏跟蹤和參與項目的演進。

如果你熱衷於構建能夠實時響應流事件的智能自主系統，那麼 Apache Flink Agents 是一個值得密切關注並加入的項目。
我們誠摯邀請開發者、貢獻者與 AI 愛好者積極參與，共同塑造基於 Apache Flink 的事件驅動 AI 未來。

瞭解更多

閲讀技術博客：《Flink Agents：基於 Apache Flink 的事件驅動 AI 智能體框架》
觀看 Flink Forward Asia 新加坡 2025 演講視頻：《Flink Agents – The Agentic AI Framework based on Apache Flink》
查看原始提案：FLIP-531: Initiate Flink Agents as a new Sub-Project

AI 的未來不僅是更聰明的模型，更是能在持續、可靠、大規模環境中行動的更智能的系統。藉助 Apache Flink Agents，我們正在攜手共建這一未來。

Apache®, Apache Flink®, Flink®, and the Flink logo are trademarks of the Apache Software Foundation in the United States and/or other countries. No endorsement by the Apache Software Foundation is implied by using these marks. All other trademarks are the property of their respective owners.

更多內容

活動推薦

複製下方鏈接或者掃描二維碼
即可快速體驗 “一體化的實時數倉聯合解決方案”
瞭解活動詳情：https://www.aliyun.com/solution/tech-solution/flink-hologres