Streaming Agents
Apache Flink® 上でイベントドリブン型エージェントをネイティブに構築、デプロイ、オーケストレーションして、組織全体のインテリジェントなリアルタイム自動化を実現します。
常時稼働、再生可能、本番環境対応
データストリームを活用し、新たなコンテキストに基づいて行動
完全マネージド型の Flink と 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
NEW: Don't miss the joint talk and tutorial with AI experts from Confluent and Databricks on building and scaling enterprise agents! Register now →
ストリーム処理と AI を統合する
データストリームにエージェントを組み込み、Flink の AI モデルを直接操作することで、開発を簡素化します。ストリーム処理ジョブ (結合、フィルタリング、充実化など) とエージェントワークフローを同一パイプラインに統合することで、運用の複雑さを軽減しつつ、すべてのエンジニアが慣れ親しんだ Flink API を使って AI エンジニアとしての作業を行えるようにします。
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.
エージェントの信頼性と安全性を確保
安全な接続、RBAC、組み込みの再生機能、ダークモードテスト、管理された追跡可能なイベントフローにより、完全な可視性と制御を維持します。
イベントドリブン型マルチエージェントシステムの活用
イベントドリブン型の設計により、Streaming Agents は厳密な依存関係なしに通信し、他のエージェントと連携し、リアルタイムの入力に適応します。Kora Engine を活用して、Orchestrator-Worker や Hierarchical などの信頼性の高いマルチエージェントパターンを実現し、無制限のエンタープライズユースケースを可能にします。Kafka の変更不可能なログにより、Streaming Agents はメモリを保持し、イベントベースのコンテキストを活用してログを再生できます。これにより、エージェントの動作を簡単に巻き戻したり、デバッグ、テスト、監査を行ったりして、より迅速かつ安全に反復処理を進めることが可能になります。
Automate High-volume Business Processes
リアルタイムの製品パーソナライゼーション
Streaming Agents は、顧客との対話データをリアルタイムで取り込み、社内システム (購入履歴、クリックストリーム、在庫情報など) のコンテキストを活用します。さらに LLM を用いて顧客の嗜好や意図を理解し、即座に商品の推奨を調整。継続的に適応することで、エンゲージメントとコンバージョンを最大化します。
異常検出と調査
運用データス トリーム (例：通話ドロップ率、信号品質、帯域幅使用量) を監視することにより、Streaming Agents は異常なパターンを検出し、データソース間で信号を相関させ、LLM を使用して考えられる根本原因と影響を評価します。その後、修復手順を開始するか、適切なチームにエスカレーションし、平均解決時間 (MTTR) を短縮します。
競争力のある価格設定
Streaming Agents は自動的に MCP ツールを起動し、注文された商品のリアルタイム価格を取得するために競合他社のウェブサイトをスクレイピングし、より低い価格に合わせて顧客の注文を更新し、顧客に節約額を電子メールで通知し、CRM システムに各価格マッチを記録します。
「優れた AI には優れたデータが必要です。Confluent は当社の信頼できる情報源となっています。Confluent のデータストリーミングプラットフォームは、AI エージェントがワークフローを自動化し、スマートシティの変革を加速するためのコンテキストとオーケストレーションを提供します。」
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