Streaming Agents

Build, deploy, and orchestrate event-driven agents natively on Apache Flink® to power intelligent real-time automation across your organization.

Always on, replayable, and production ready

Living in data streams to act on fresh context

Built on fully managed Flink and Kafka


What are Streaming Agents?

Streaming Agents enable you to build, test, deploy, and orchestrate event-driven agents using fully managed Flink and Kafka on a unified platform. With access to real-time contextualized data, they’re uniquely suited for enterprise workflows – monitoring and taking instant, informed action the moment operational events occur.

Whether you’re automating fraud prevention or personalizing product recommendations, Streaming Agents help you turn agents from brittle demos into production-ready, event-driven multi-agent systems.

Watch Demo

Streaming Agents - AI Day Boston banner thumbnail


NEW: Join us at AI Day for Developers in Boston on Sept. 24 for a hands-on Streaming Agents workshop and hackathon with a chance to win exciting prizes. Register now →

Unify stream processing and AI

Simplify development by embedding agents in the data stream and directly working with AI models in Flink. Combine stream processing jobs (e.g., join, filter, enrich) and agentic workflows in the same pipeline, reducing operational complexity while empowering every engineer to be an AI engineer using familiar Flink APIs.

Tap into fresh context

Enterprises need agents to be the eyes and ears for the business in motion, but most agents lack real-time awareness. Running as Flink jobs in stream processing pipelines, Streaming Agents can access the latest, most accurate view of the business, at the moment a decision needs to be made – zero data polling or delay. They’re always on, state-aware, and retain context over time.

Seamlessly integrate with any model, tool, and data system

Integrate without stitching together disparate systems. Use your preferred tools and Flink APIs with native support for connecting to large language models (LLMs) and embedding models, tool calling with Model Context Protocol (MCP), and data enrichment from other systems with External Tables and Vector Search.

Ensure agents are trustworthy and secure

Maintain full visibility and control with secure connections, RBAC, built-in replayability, dark mode testing, and governed, traceable event flows.

Streaming Agents - event-driven design


Unlock event-driven multi-agent systems

Event-driven by design, Streaming Agents communicate without rigid dependencies, collaborate with other agents, and adapt to real-time inputs. Powered by Kora Engine, this unlocks reliable multi-agent patterns such as Orchestrator-Worker or Hierarchical to enable unlimited enterprise use cases.

Kafka’s immutable log provides replayability where Streaming Agents have memory and context is event-based – this helps you easily rewind, debug, test, and audit agent behavior to iterate faster, safely.

Automate high-volume business processes

Real-time product personalization

Streaming Agents ingest live customer interaction data, leverage context from internal systems (e.g., purchase history, clickstream, inventory), use an LLM to understand preferences and intent, and then instantly tailor product recommendations–continuously adapting to maximize engagement and conversion.

Anomaly detection & investigation

By monitoring operational data streams–e.g., call drop rates, signal quality, bandwidth usage–Streaming Agents detect unusual patterns, correlate signals across data sources, use an LLM to assess likely root causes and impact, then trigger remediation steps or escalate to the right teams–enabling faster mean time to resolution (MTTR).

Competitive pricing

Streaming Agents automatically trigger MCP tools to scrape competitor websites for real-time pricing on ordered products, update the customer’s order to match lower prices, notify the customer of their savings via email, and log each price match in a CRM system.

Get Started with Streaming Agents

Ready to build your first agent? Sign up and receive $400 to spend during your first 30 days.

Use Streaming Agents on Confluent Cloud to make production-ready, event-driven multi-agent systems a reality.

  • ✔ Unify data processing and AI workflows
  • ✔ Use fresh context for intelligent decision-making
  • ✔ Integrate with any model, tool, and data system
  • ✔ Iterate faster, safely, with the industry's only data streaming governance suite

Confluent Cloud

完全マネージド型、クラウドネイティブの Apache Kafka® サービス

  • アイスランド
  • アイルランド
  • アゼルバイジャン
  • アフガニスタン
  • アメリカ合衆国
  • アメリカ領ヴァージン諸島
  • アメリカ領サモア
  • アラブ首長国連邦
  • アルジェリア
  • アルゼンチン
  • アルバ
  • アルバニア
  • アルメニア
  • アンギラ
  • アンゴラ
  • アンティグア・バーブーダ
  • アンドラ
  • イエメン
  • イギリス
  • イギリス領インド洋地域
  • イギリス領ヴァージン諸島
  • イスラエル
  • イタリア
  • イラク
  • イラン・イスラム共和国
  • インド
  • インドネシア
  • ウォリス・フツナ
  • ウガンダ
  • ウクライナ
  • ウズベキスタン
  • ウルグアイ
  • エクアドル
  • エジプト
  • エストニア
  • エチオピア
  • エリトリア
  • エルサルバドル
  • オーストラリア
  • オーストリア
  • オーランド諸島
  • オマーン
  • オランダ
  • ガーナ
  • カーボベルデ
  • ガーンジー
  • ガイアナ
  • カザフスタン
  • カタール
  • カナダ
  • ガボン
  • カメルーン
  • ガンビア
  • カンボジア
  • ギニア
  • ギニアビサウ
  • キプロス
  • キューバ
  • キュラソー
  • ギリシャ
  • キリバス
  • キルギス
  • グアテマラ
  • グアドループ
  • グアム
  • クウェート
  • クック諸島
  • グリーンランド
  • クリスマス島
  • グレナダ
  • クロアチア
  • ケイマン諸島
  • ケニア
  • コートジボワール
  • ココス(キーリング)諸島
  • コスタリカ
  • コモロ
  • コロンビア
  • コンゴ共和国
  • コンゴ民主共和国
  • サウジアラビア
  • サウスジョージア・サウスサンドウィッチ諸島
  • サモア
  • サン・バルテルミー
  • サン・マルタン(フランス領)
  • サントメ・プリンシペ
  • ザンビア
  • サンピエール島・ミクロン島
  • サンマリノ
  • シエラレオネ
  • ジブチ
  • ジブラルタル
  • ジャージー
  • ジャマイカ
  • ジョージア
  • シリア・アラブ共和国
  • シンガポール
  • シント・マールテン(オランダ領)
  • ジンバブエ
  • スーダン
  • スイス
  • スヴァールバル諸島およびヤンマイエン島
  • スウェーデン
  • スペイン
  • スリナム
  • スリランカ
  • スロバキア
  • スロベニア
  • スワジランド
  • セーシェル
  • セネガル
  • セルビア
  • セントクリストファー・ネイビス
  • セントビンセントおよびグレナディーン諸島
  • セントヘレナ・アセンションおよびトリスタンダクーニャ
  • セントルシア
  • ソマリア
  • ソロモン諸島
  • タークス・カイコス諸島
  • タイ
  • タジキスタン
  • タンザニア
  • チェコ
  • チャド
  • チュニジア
  • チリ
  • ツバル
  • デンマーク
  • トーゴ
  • ドイツ
  • トケラウ
  • ドミニカ共和国
  • ドミニカ国
  • トリニダード・トバゴ
  • トルクメニスタン
  • トルコ
  • トンガ
  • ナイジェリア
  • ナウル
  • ナミビア
  • ニウエ
  • ニカラグア
  • ニジェール
  • ニューカレドニア
  • ニュージーランド
  • ネパール
  • ノーフォーク島
  • ノルウェー
  • ハード島とマクドナルド諸島
  • バーレーン
  • ハイチ
  • パキスタン
  • バチカン市国
  • パナマ
  • バヌアツ
  • バハマ
  • パプアニューギニア
  • バミューダ
  • パラオ
  • パラグアイ
  • バルバドス
  • パレスチナ
  • ハンガリー
  • バングラデシュ
  • ピトケアン
  • ブータン
  • ブーベ島
  • フィジー
  • フィリピン
  • フィンランド
  • プエルトリコ
  • フェロー諸島
  • フォークランド(マルビナス)諸島
  • ブラジル
  • フランス
  • フランス領ギアナ
  • フランス領ポリネシア
  • フランス領南方・南極地域
  • ブルガリア
  • ブルキナファソ
  • ブルネイ・ダルサラーム
  • ブルンジ
  • ベトナム
  • ベナン
  • ベネズエラ・ボリバル共和国
  • ベラルーシ
  • ベリーズ
  • ペルー
  • ベルギー
  • ポーランド
  • ボスニア・ヘルツェゴビナ
  • ボツワナ
  • ボネール、シント・ユースタティウスおよびサバ
  • ボリビア多民族国
  • ポルトガル
  • ホンジュラス
  • マーシャル諸島
  • マカオ
  • マダガスカル
  • マヨット
  • マラウイ
  • マリ
  • マルタ
  • マルティニーク
  • マレーシア
  • マン島
  • ミクロネシア連邦
  • ミャンマー
  • メキシコ
  • モーリシャス
  • モーリタニア
  • モザンビーク
  • モナコ
  • モルディブ
  • モルドバ共和国
  • モロッコ
  • モンゴル
  • モンテネグロ
  • モントセラト
  • ヨルダン
  • ラオス人民民主共和国
  • ラトビア
  • リトアニア
  • リビア
  • リヒテンシュタイン
  • リベリア
  • ルーマニア
  • ルクセンブルク
  • ルワンダ
  • レソト
  • レバノン
  • レユニオン
  • ロシア連邦
  • 中央アフリカ共和国
  • 中華人民共和国
  • 北マケドニア
  • 北マリアナ諸島
  • 南アフリカ
  • 南スーダン
  • 南極
  • 台湾
  • 合衆国領有小離島
  • 大韓民国
  • 日本
  • 朝鮮民主主義人民共和国
  • 東ティモール
  • 西サハラ
  • 赤道ギニア
  • 香港

すでにアカウントをお持ちの場合はログイン

「無料で利用開始」をクリックすることにより、サービス利用規約プライバシーポリシーの内容に同意するものとします。

Accelerate innovation with Confluent and leading AI partners

Click each partner logo to learn how we work together to help you implement real-time AI.




クラウドプロバイダー
AI プラットフォームとツール
システムインテグレーター

Additional resources

A Guide to Event-Driven Design for Agents and Multi-Agent Systems

Powering AI Agents with Anthropic’s MCP and Confluent

A2A, MCP, Kafka and Flink: The New Stack for AI Agents

Streaming Agents Docs and How to Get Started