編譯 | 云昭

出品 | 51CTO技術(shù)棧（微信號：blog51cto）

智能體（Agent）是個不可逆的趨勢。但今天的AI 智能體似乎還處于一個“前標(biāo)準(zhǔn)化”階段。

這些雨后春筍般的智能體越來越多，性能強(qiáng)大、增長迅速，但彼此之間卻無法協(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)濟(jì)體。

不過，這種狀況正在發(fā)生改變。一個新的技術(shù)棧正在形成，它支撐著下一代“互聯(lián)網(wǎng)”的發(fā)展——這次不是為了人類瀏覽網(wǎng)頁，而是為了自治的智能體在系統(tǒng)之間協(xié)作。核心由四個開放組件組成：

• Google 的 Agent2Agent（A2A）：一種智能體發(fā)現(xiàn)和通信協(xié)議
• Anthropic 的 Model Context Protocol（MCP）：用于工具使用與外部上下文訪問的標(biāo)準(zhǔn)
• Apache Kafka：一個事件驅(qū)動的通信結(jié)構(gòu)，提供可靠、解耦的協(xié)調(diào)機(jī)制
• Apache Flink：一個實時處理引擎，用于豐富、監(jiān)控并響應(yīng)智能體活動流

本文中，我們將探討這些技術(shù)如何協(xié)同工作，為何僅靠協(xié)議還不夠，以及這個新棧如何提供從孤立機(jī)器人走向動態(tài)、智能協(xié)作生態(tài)所需的基礎(chǔ)設(shè)施。

1.問題：碎片化的智能體，脆弱的基礎(chǔ)設(shè)施

至少現(xiàn)在看來，智能體看起來是一個不可逆的趨勢。而且，大多數(shù)公司將不僅部署一個AI智能體，而是幾十個。這些智能體將編寫代碼、分類支持工單、分析客戶數(shù)據(jù)、管理員工入職、監(jiān)控基礎(chǔ)設(shè)施等等。

但當(dāng)下的工具鏈尚未為這一未來做好準(zhǔn)備。

Agent孤島 （圖源：confluent）

那么，問題來了：

• 智能體彼此無法通信：每個智能體運行在自己的“沙盒”中，CRM 智能體不知道數(shù)據(jù)倉庫智能體剛發(fā)現(xiàn)了什么，客服智能體無法響應(yīng)監(jiān)控智能體剛剛標(biāo)記的異常。
• 工具使用方式脆弱且定制化嚴(yán)重：沒有統(tǒng)一的方式來調(diào)用工具或 API，結(jié)果就是集成方式硬編碼、邏輯不可重用。
• 框架不一致：不同的運行時以不同方式構(gòu)建智能體——有的像聊天機(jī)器人，有的像DAG（有向無環(huán)圖），有的像遞歸規(guī)劃器。沒有可移植的執(zhí)行層，也沒有共享狀態(tài)。
• 智能體被當(dāng)作一次性腳本開發(fā)：它們通常是線性、同步、短暫的原型，但現(xiàn)實系統(tǒng)需要處理重試、失敗、協(xié)調(diào)、日志和擴(kuò)展能力，這些都需要基礎(chǔ)設(shè)施。
• 缺乏協(xié)作主干：沒有事件總線、共享內(nèi)存或可追蹤的行為歷史。一切都鎖定在直接的HTTP調(diào)用中，或者深埋于日志中。

結(jié)果就是：信息孤島、重復(fù)建設(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、安全認(rèn)證與權(quán)限控制，確保默認(rèn)安全。

A2A 的優(yōu)勢在于：它并不重造輪子，而是復(fù)用 HTTP、SMTP 等標(biāo)準(zhǔn)的成熟經(jīng)驗，易于集成和推廣。

Anthropic 的 MCP 解決的是智能體如何使用工具、調(diào)用 API 和訪問上下文的問題，也就是智能體如何“行動”。它標(biāo)準(zhǔn)化了函數(shù)調(diào)用、外部集成、上下文注入等行為。

可以理解為：

• MCP 是智能體的“工具箱”；
• A2A 是智能體的“對話協(xié)議”。

二者結(jié)合，構(gòu)建出智能體網(wǎng)絡(luò)的藍(lán)圖：

• MCP 提供單體智能（individual intelligence）；
• A2A 激發(fā)群體智能（collective intelligence）。

但光有協(xié)議還不夠。要在企業(yè)環(huán)境中支撐成百上千個智能體協(xié)作，還需要強(qiáng)大的通信基礎(chǔ)設(shè)施。

3.除了協(xié)議，誰來當(dāng)事件驅(qū)動的主干？

想象一下，如果一家公司所有員工只能通過私聊來溝通，一個個單獨發(fā)消息來協(xié)調(diào)項目，信息同步將變得混亂不堪，無法擴(kuò)展。

這正是智能體生態(tài)系統(tǒng)在缺乏消息主干時的困境。

每個智能體都要手動知道對方是誰、在哪、是否在線——這會迅速變得難以管理。

這時，Apache Kafka 和 Apache Flink 就登場了。眾所周知，Kafka是一個高吞吐、持久化的分布式事件流平臺，用于發(fā)布/訂閱實時事件流，具有解耦生產(chǎn)者與消費者、可重放、易擴(kuò)展等特點。而Flink作為實時流式計算引擎，支持狀態(tài)管理、高吞吐、低延遲的事件處理，可對流進(jìn)行過濾、聚合、觸發(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ā)下一步操作。
• 容錯與擴(kuò)展：Flink 可橫向擴(kuò)展，保持狀態(tài)，支持長任務(wù)的中斷恢復(fù)。
• 流原生協(xié)作：智能體通過事件流異步協(xié)作，不必同步阻塞。

A2A, MCP, Kafka,Flink 協(xié)作一覽（圖源：confluent）

總結(jié)如下：

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 提供通信與工具標(biāo)準(zhǔn)；
• Kafka與Flink 提供實時協(xié)調(diào)、觀測與彈性基礎(chǔ)；
• 框架如 LangGraph、CrewAI、ADK 則實現(xiàn)“如何構(gòu)建”的標(biāo)準(zhǔn)化。

未來不是單一智能體的堆砌，而是智能體之間的連接、協(xié)作與演化。

下次你在構(gòu)建智能體時，不僅要問：它能做什么？更要問：它能否溝通？能否協(xié)調(diào)？能否進(jìn)化？

因為未來不是“智能體驅(qū)動”，而是“智能體協(xié)同”。

參考鏈接： https://thenewstack.io/a2a-mcp-kafka-and-flink-the-new-stack-for-ai-agents/