編譯 | 云昭

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

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

這些雨后春筍般的智能體越來(lái)越多，性能強(qiáng)大、增長(zhǎng)迅速，但彼此之間卻無(wú)法協(xié)作——有的智能體用來(lái)分析數(shù)據(jù)，有的用來(lái)編寫代碼，有的用來(lái)自動(dòng)化客戶關(guān)系管理（CRM）工作流，但它們彼此孤立，互不往來(lái)。

這就好比幾十年前的互聯(lián)網(wǎng)：在萬(wàn)維網(wǎng)出現(xiàn)HTTP協(xié)議之前，在電子郵件擁有SMTP協(xié)議之前，我們?cè)萦诙ㄖ萍?、系統(tǒng)碎片化和脆弱工作流的困境中。

直到開(kāi)放協(xié)議與共享基礎(chǔ)設(shè)施的出現(xiàn)，互聯(lián)網(wǎng)才真正實(shí)現(xiàn)了規(guī)模化，催生了現(xiàn)代網(wǎng)絡(luò)、全球通信和全新經(jīng)濟(jì)體。

不過(guò)，這種狀況正在發(fā)生改變。

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

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

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

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

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

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

Agent孤島 （圖源：confluent）

那么，問(wèn)題來(lái)了：

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

結(jié)果就是：信息孤島、重復(fù)建設(shè)、系統(tǒng)脆弱。那該怎么辦？

解決方案不是打造一個(gè)巨型平臺(tái)，而是構(gòu)建一個(gè)開(kāi)放協(xié)議、事件驅(qū)動(dòng)架構(gòu)與實(shí)時(shí)處理組成的共享技術(shù)棧。

2.A2A與MCP：智能體如何“對(duì)話”與“行動(dòng)”

今天的智能體生態(tài)就像早期互聯(lián)網(wǎng)：每個(gè)系統(tǒng)都能完成有用的工作，但彼此孤立、不兼容。就像沒(méi)有HTTP的瀏覽器無(wú)法與服務(wù)器交流一樣，AI智能體也無(wú)法輕松發(fā)現(xiàn)彼此或協(xié)作。

Google 的 A2A 協(xié)議試圖改變這一點(diǎn)：它不是另一個(gè)智能體框架，而是一個(gè)通用協(xié)議，無(wú)論由誰(shuí)構(gòu)建、運(yùn)行在哪，任何智能體都能連接。

A2A 就像 HTTP 一樣，為智能體定義了一種共享語(yǔ)言，讓它們可以：

• 通過(guò) AgentCard（JSON 格式）宣布自身能力和交互方式；
• 使用結(jié)構(gòu)化交互（基于 JSON-RPC）發(fā)送任務(wù)請(qǐng)求，并接收結(jié)果或產(chǎn)出；
• 利用 SSE（Server-Sent Events）推送任務(wù)狀態(tài)，實(shí)現(xiàn)實(shí)時(shí)反饋；
• 交換富內(nèi)容（文件、結(jié)構(gòu)化數(shù)據(jù)、表單等）；
• 通過(guò) HTTPS、安全認(rèn)證與權(quán)限控制，確保默認(rèn)安全。

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

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

可以理解為：

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

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

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

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

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

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

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

每個(gè)智能體都要手動(dòng)知道對(duì)方是誰(shuí)、在哪、是否在線——這會(huì)迅速變得難以管理。

這時(shí)，Apache Kafka 和 Apache Flink 就登場(chǎng)了。眾所周知，Kafka是一個(gè)高吞吐、持久化的分布式事件流平臺(tái)，用于發(fā)布/訂閱實(shí)時(shí)事件流，具有解耦生產(chǎn)者與消費(fèi)者、可重放、易擴(kuò)展等特點(diǎn)。而Flink作為實(shí)時(shí)流式計(jì)算引擎，支持狀態(tài)管理、高吞吐、低延遲的事件處理，可對(duì)流進(jìn)行過(guò)濾、聚合、觸發(fā)動(dòng)作等。

二者搭配起來(lái)，非常如魚得水——Kafka 好比血液循環(huán)系統(tǒng)；Flink則是神經(jīng)反射系統(tǒng)。Kafka 加上 Flink就會(huì)為智能體生態(tài)提供基礎(chǔ)設(shè)施。

Kafka 和 Flink 提供了解決協(xié)議通信難題的“基礎(chǔ)支撐”：

• 解耦通信：智能體發(fā)布事件（如“任務(wù)完成”、“發(fā)現(xiàn)洞察”）到 Kafka 主題，訂閱者無(wú)需提前知道發(fā)送者是誰(shuí)。
• 可觀測(cè)性與可重放性：Kafka 日志是時(shí)間有序、可追蹤、可重放的。
• 實(shí)時(shí)決策：Flink 可實(shí)時(shí)響應(yīng)流事件，動(dòng)態(tài)過(guò)濾、聚合、觸發(fā)下一步操作。
• 容錯(cuò)與擴(kuò)展：Flink 可橫向擴(kuò)展，保持狀態(tài)，支持長(zhǎng)任務(wù)的中斷恢復(fù)。
• 流原生協(xié)作：智能體通過(guò)事件流異步協(xié)作，不必同步阻塞。

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

總結(jié)如下：

4.未來(lái)：構(gòu)建智能體互聯(lián)網(wǎng)

我們正站在軟件演化的關(guān)鍵節(jié)點(diǎn)。

正如互聯(lián)網(wǎng)協(xié)議（如HTTP、SMTP）與基礎(chǔ)設(shè)施（如TCP/IP）曾開(kāi)啟全球互聯(lián)的新時(shí)代，如今的A2A、MCP、Kafka、Flink，也在構(gòu)建一個(gè)全新的“智能體互聯(lián)網(wǎng)”。

這個(gè)新技術(shù)棧不再為人類瀏覽頁(yè)面而設(shè)計(jì)，而是為自治系統(tǒng)之間的推理、決策與行動(dòng)而生。

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

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

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

因?yàn)槲磥?lái)不是“智能體驅(qū)動(dòng)”，而是“智能體協(xié)同”。

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

?本文轉(zhuǎn)載自??51CTO技術(shù)棧??，作者：云昭