Apache Flink 社区发布了 Apache Flink Agents 0.1.0 预览版，这是 Flink 的一个全新子项目。
该项目旨在将事件驱动的 AI 智能体能力集成到 Flink 流处理框架中。该项目统一了流处理与智能体功能，使开发者能够在同一框架内构建实时响应的 AI 应用。
解决的核心问题
当前 AI 智能体主要用于聊天机器人等交互式场景，采用同步、一次性的交互模式。但企业实际业务中存在大量需要实时智能决策的场景。
以电商支付为例，系统每秒处理数万笔交易，当支付失败时，传统规则引擎只能执行预设流程。而通过 Flink Agents，系统可以实时调用 AI 模型分析失败原因，智能决定是重试支付、切换渠道还是联系客户，整个过程在毫秒级完成。
再如金融风控场景，面对不断演变的欺诈模式，固定规则难以应对。Flink Agents 能够实时分析交易流，结合历史数据和 AI 模型动态调整风控策略，同时确保系统故障时不丢失任何交易记录。
这些场景要求系统必须 7×24 小时持续运行、处理海量并发、保证容错能力，同时具备智能决策能力——这正是 Flink Agents 要解决的问题。
核心能力
该版本提供了以下关键特性：
大规模实时处理 ：基于 Flink 的分布式引擎，支持高吞吐量事件流的毫秒级处理。
数据与 AI 集成 ：支持将 DataStream 和 Table API 作为智能体的输入输出，实现结构化数据处理与 AI 文本处理的无缝对接。
精确一次语义 ：通过结合 Flink 检查点机制与外部预写日志，确保智能体操作的一致性，避免重复执行或数据丢失。
多语言支持 ：提供 Python 和 Java 双语言 API。
生态集成 ：支持主流大语言模型、向量存储以及 MCP 服务器上的工具集成。
可观测性 ：采用事件驱动编排，所有操作可追踪审计，便于理解智能体决策过程。
相关链接：
- 下载地址：https://flink.apache.org/downloads/#apache-flink-agents
- 文档：https://nightlies.apache.org/flink/flink-agents-docs-main/
- GitHub：https://github.com/apache/flink-agents/
关注公众号回复“进群”入群讨论。