四劍客聯(lián)手打造下一代互聯(lián)網(wǎng)!智能體互聯(lián)時代將至!A2A、MCP、Kafka 與 Flink如何強強聯(lián)手? 原創(chuàng)
編譯 | 云昭
出品 | 51CTO技術(shù)棧(微信號:blog51cto)
智能體(Agent)是個不可逆的趨勢。但今天的AI 智能體似乎還處于一個“前標準化”階段。
這些雨后春筍般的智能體越來越多,性能強大、增長迅速,但彼此之間卻無法協(xié)作——有的智能體用來分析數(shù)據(jù),有的用來編寫代碼,有的用來自動化客戶關(guān)系管理(CRM)工作流,但它們彼此孤立,互不往來。
這就好比幾十年前的互聯(lián)網(wǎng):在萬維網(wǎng)出現(xiàn)HTTP協(xié)議之前,在電子郵件擁有SMTP協(xié)議之前,我們曾陷于定制集成、系統(tǒng)碎片化和脆弱工作流的困境中。
直到開放協(xié)議與共享基礎(chǔ)設(shè)施的出現(xiàn),互聯(lián)網(wǎng)才真正實現(xiàn)了規(guī)?;?,催生了現(xiàn)代網(wǎng)絡(luò)、全球通信和全新經(jīng)濟體。
不過,這種狀況正在發(fā)生改變。
一個新的技術(shù)棧正在形成,它支撐著下一代“互聯(lián)網(wǎng)”的發(fā)展——這次不是為了人類瀏覽網(wǎng)頁,而是為了自治的智能體在系統(tǒng)之間協(xié)作。核心由四個開放組件組成:
- Google 的 Agent2Agent(A2A):一種智能體發(fā)現(xiàn)和通信協(xié)議
- Anthropic 的 Model Context Protocol(MCP):用于工具使用與外部上下文訪問的標準
- Apache Kafka:一個事件驅(qū)動的通信結(jié)構(gòu),提供可靠、解耦的協(xié)調(diào)機制
- Apache Flink:一個實時處理引擎,用于豐富、監(jiān)控并響應(yīng)智能體活動流
本文中,我們將探討這些技術(shù)如何協(xié)同工作,為何僅靠協(xié)議還不夠,以及這個新棧如何提供從孤立機器人走向動態(tài)、智能協(xié)作生態(tài)所需的基礎(chǔ)設(shè)施。
1.問題:碎片化的智能體,脆弱的基礎(chǔ)設(shè)施
至少現(xiàn)在看來,智能體看起來是一個不可逆的趨勢。而且,大多數(shù)公司將不僅部署一個AI智能體,而是幾十個。這些智能體將編寫代碼、分類支持工單、分析客戶數(shù)據(jù)、管理員工入職、監(jiān)控基礎(chǔ)設(shè)施等等。
但當下的工具鏈尚未為這一未來做好準備。
Agent孤島 (圖源:confluent)
那么,問題來了:
- 智能體彼此無法通信:每個智能體運行在自己的“沙盒”中,CRM 智能體不知道數(shù)據(jù)倉庫智能體剛發(fā)現(xiàn)了什么,客服智能體無法響應(yīng)監(jiān)控智能體剛剛標記的異常。
- 工具使用方式脆弱且定制化嚴重:沒有統(tǒng)一的方式來調(diào)用工具或 API,結(jié)果就是集成方式硬編碼、邏輯不可重用。
- 框架不一致:不同的運行時以不同方式構(gòu)建智能體——有的像聊天機器人,有的像DAG(有向無環(huán)圖),有的像遞歸規(guī)劃器。沒有可移植的執(zhí)行層,也沒有共享狀態(tài)。
- 智能體被當作一次性腳本開發(fā):它們通常是線性、同步、短暫的原型,但現(xiàn)實系統(tǒng)需要處理重試、失敗、協(xié)調(diào)、日志和擴展能力,這些都需要基礎(chǔ)設(shè)施。
- 缺乏協(xié)作主干:沒有事件總線、共享內(nèi)存或可追蹤的行為歷史。一切都鎖定在直接的HTTP調(diào)用中,或者深埋于日志中。
結(jié)果就是:信息孤島、重復建設(shè)、系統(tǒng)脆弱。那該怎么辦?
解決方案不是打造一個巨型平臺,而是構(gòu)建一個開放協(xié)議、事件驅(qū)動架構(gòu)與實時處理組成的共享技術(shù)棧。
2.A2A與MCP:智能體如何“對話”與“行動”
今天的智能體生態(tài)就像早期互聯(lián)網(wǎng):每個系統(tǒng)都能完成有用的工作,但彼此孤立、不兼容。就像沒有HTTP的瀏覽器無法與服務(wù)器交流一樣,AI智能體也無法輕松發(fā)現(xiàn)彼此或協(xié)作。
Google 的 A2A 協(xié)議試圖改變這一點:它不是另一個智能體框架,而是一個通用協(xié)議,無論由誰構(gòu)建、運行在哪,任何智能體都能連接。
A2A 就像 HTTP 一樣,為智能體定義了一種共享語言,讓它們可以:
- 通過 AgentCard(JSON 格式)宣布自身能力和交互方式;
- 使用結(jié)構(gòu)化交互(基于 JSON-RPC)發(fā)送任務(wù)請求,并接收結(jié)果或產(chǎn)出;
- 利用 SSE(Server-Sent Events)推送任務(wù)狀態(tài),實現(xiàn)實時反饋;
- 交換富內(nèi)容(文件、結(jié)構(gòu)化數(shù)據(jù)、表單等);
- 通過 HTTPS、安全認證與權(quán)限控制,確保默認安全。
A2A 的優(yōu)勢在于:它并不重造輪子,而是復用 HTTP、SMTP 等標準的成熟經(jīng)驗,易于集成和推廣。但這只是其中一半。
Anthropic 的 MCP 解決的是智能體如何使用工具、調(diào)用 API 和訪問上下文的問題,也就是智能體如何“行動”。它標準化了函數(shù)調(diào)用、外部集成、上下文注入等行為。
可以理解為:
- MCP 是智能體的“工具箱”;
- A2A 是智能體的“對話協(xié)議”。
二者結(jié)合,構(gòu)建出智能體網(wǎng)絡(luò)的藍圖:
- MCP 提供單體智能(individual intelligence);
- A2A 激發(fā)群體智能(collective intelligence)。
但光有協(xié)議還不夠。要在企業(yè)環(huán)境中支撐成百上千個智能體協(xié)作,還需要強大的通信基礎(chǔ)設(shè)施。
3.除了協(xié)議,誰來當事件驅(qū)動的主干?
想象一下,如果一家公司所有員工只能通過私聊來溝通,一個個單獨發(fā)消息來協(xié)調(diào)項目,信息同步將變得混亂不堪,無法擴展。
這正是智能體生態(tài)系統(tǒng)在缺乏消息主干時的困境。
每個智能體都要手動知道對方是誰、在哪、是否在線——這會迅速變得難以管理。
這時,Apache Kafka 和 Apache Flink 就登場了。眾所周知,Kafka是一個高吞吐、持久化的分布式事件流平臺,用于發(fā)布/訂閱實時事件流,具有解耦生產(chǎn)者與消費者、可重放、易擴展等特點。而Flink作為實時流式計算引擎,支持狀態(tài)管理、高吞吐、低延遲的事件處理,可對流進行過濾、聚合、觸發(fā)動作等。
二者搭配起來,非常如魚得水——Kafka 好比血液循環(huán)系統(tǒng);Flink則是神經(jīng)反射系統(tǒng)。Kafka 加上 Flink就會為智能體生態(tài)提供基礎(chǔ)設(shè)施。
Kafka 和 Flink 提供了解決協(xié)議通信難題的“基礎(chǔ)支撐”:
- 解耦通信:智能體發(fā)布事件(如“任務(wù)完成”、“發(fā)現(xiàn)洞察”)到 Kafka 主題,訂閱者無需提前知道發(fā)送者是誰。
- 可觀測性與可重放性:Kafka 日志是時間有序、可追蹤、可重放的。
- 實時決策:Flink 可實時響應(yīng)流事件,動態(tài)過濾、聚合、觸發(fā)下一步操作。
- 容錯與擴展:Flink 可橫向擴展,保持狀態(tài),支持長任務(wù)的中斷恢復。
- 流原生協(xié)作:智能體通過事件流異步協(xié)作,不必同步阻塞。
A2A, MCP, Kafka,Flink 協(xié)作一覽(圖源:confluent)
總結(jié)如下:
組件 | 功能 |
A2A | 定義智能體“如何對話” |
MCP | 定義智能體“如何行動” |
Kafka | 定義消息“如何流動” |
Flink | 定義這些流“如何被理解與執(zhí)行” |
4.未來:構(gòu)建智能體互聯(lián)網(wǎng)
我們正站在軟件演化的關(guān)鍵節(jié)點。
正如互聯(lián)網(wǎng)協(xié)議(如HTTP、SMTP)與基礎(chǔ)設(shè)施(如TCP/IP)曾開啟全球互聯(lián)的新時代,如今的A2A、MCP、Kafka、Flink,也在構(gòu)建一個全新的“智能體互聯(lián)網(wǎng)”。
這個新技術(shù)棧不再為人類瀏覽頁面而設(shè)計,而是為自治系統(tǒng)之間的推理、決策與行動而生。
- A2A與MCP 提供通信與工具標準;
- Kafka與Flink 提供實時協(xié)調(diào)、觀測與彈性基礎(chǔ);
- 框架如 LangGraph、CrewAI、ADK 則實現(xiàn)“如何構(gòu)建”的標準化。
未來不是單一智能體的堆砌,而是智能體之間的連接、協(xié)作與演化。
下次你在構(gòu)建智能體時,不僅要問:它能做什么?更要問:它能否溝通?能否協(xié)調(diào)?能否進化?
因為未來不是“智能體驅(qū)動”,而是“智能體協(xié)同”。
參考鏈接: ?? https://thenewstack.io/a2a-mcp-kafka-and-flink-the-new-stack-for-ai-agents/??
?本文轉(zhuǎn)載自??51CTO技術(shù)棧??,作者:云昭
