Streaming Agents
Apache Flink® 上でイベントドリブン型エージェントをネイティブに構築、デプロイ、オーケストレーションして、組織全体のインテリジェントなリアルタイム自動化を実現します。
常時稼働、再生可能、本番環境対応
データストリームを活用し、新たなコンテキストに基づいて行動
完全マネージド型の Flink と Kafka 上に構築
Streaming Agents とは何ですか？
Streaming Agents は、統合プラットフォーム上で完全マネージド型の Flink と Kafka を使用して、イベントドリブンエージェントの構築、テスト、デプロイ、およびオーケストレーションを可能にします。リアルタイムでコンテキスト化されたデータにアクセスできるため、エンタープライズワークフローに最適であり、監視を継続し、業務上のイベントが発生した瞬間に、即座に情報に基づいた行動を取ることができます。
不正行為の防止を自動化する場合も、製品の推奨をパーソナライズする場合も、Streaming Agents は、デモ用の脆弱なエージェントを、本番対応のイベント駆動型マルチエージェントシステムに変えるのに役立ちます。
デモを見る
新着情報：シアトルで開催される AI Day で、Macbook Pro や iPhone などの賞品がもらえる実践的なワークショップとハッカソンに参加しましょう！今すぐ登録 →
ストリーム処理と AI を統合する
データストリームにエージェントを組み込み、Flink の AI モデルを直接操作することで、開発を簡素化します。ストリーム処理ジョブ (結合、フィルタリング、充実化など) とエージェントワークフローを同一パイプラインに統合することで、運用の複雑さを軽減しつつ、すべてのエンジニアが慣れ親しんだ Flink API を使って AI エンジニアとしての作業を行えるようにします。
最新のコンテキストを活用
企業には、進行中のビジネスを監視する「目と耳」となるエージェントが必要ですが、多くのエージェントはリアルタイムでの認識能力が十分ではありません。Streaming Agents はストリーム処理パイプライン上で Flink ジョブとして実行され、意思決定が必要な瞬間に、ビジネスの最新かつ正確な情報に即座にアクセスできます。データのポーリングや遅延は一切なく、常時稼働で状態を認識し、時間が経過してもコンテキストを保持します。
あらゆるモデル、ツール、データシステムとシームレスに統合
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), A2A, and data enrichment from other systems with External Tables & Search (e.g., vector search, text search, key search).
エージェントの信 頼性と安全性を確保
安全な接続、RBAC、組み込みの再生機能、ダークモードテスト、管理された追跡可能なイベントフローにより、完全な可視性と制御を維持します。
イベントドリブン型マルチエージェントシステムの活用
イベントドリブン型の設計により、Streaming Agents は厳密な依存関係なしに通信し、他のエージェントと連携し、リアルタイムの入力に適応します。Kora Engine を活用して、Orchestrator-Worker や Hierarchical などの信頼性の高いマルチエージェントパターンを実現し、無制限のエンタープライズユースケースを可能にします。Kafka の変更不可能なログにより、Streaming Agents はメモリを保持し、イベントベースのコンテキストを活用してログを再生できます。これにより、エージェントの動作を簡単に巻き戻したり、デバッグ、テスト、監査を行ったりして、より迅速かつ安全に反復処理を進めることが可能になります。
大量のビジネスプロセスを自動化
リアルタイムの製品パーソナライゼーション
Streaming Agents は、顧客との対話データをリアルタイムで取り込み、社内システム (購入履歴、クリックストリーム、在庫情報など) のコンテキストを活用します。さらに LLM を用いて顧客の嗜好や意図を理解し、即座に商品の推奨を調整。継続的に適応することで、エンゲージメントとコンバージョンを最大化します。
異常検出と調査
運用データストリーム (例：通話ドロップ率、信号品質、帯域幅使用量) を監視することにより、Streaming Agents は異常なパターンを検出し、データソース間で信号を相関させ、LLM を使用 して考えられる根本原因と影響を評価します。その後、修復手順を開始するか、適切なチームにエスカレーションし、平均解決時間 (MTTR) を短縮します。
競争力のある価格設定
Streaming Agents は自動的に MCP ツールを起動し、注文された商品のリアルタイム価格を取得するために競合他社のウェブサイトをスクレイピングし、より低い価格に合わせて顧客の注文を更新し、顧客に節約額を電子メールで通知し、CRM システムに各価格マッチを記録します。
「優れた AI には優れたデータが必要です。Confluent は当社の信頼できる情報源となっています。Confluent のデータストリーミングプラットフォームは、AI エージェントがワークフローを自動化し、スマートシティの変革を加速するためのコンテキストとオーケストレーションを提供します。」
最初のエージェントを作る準備はできていますか？登録すると、最初の30日間に使える400ドルのクレジットが付与されます。
Confluent Cloud 上で Streaming Agents を使用し、本番環境に対応するイベントドリブン型マルチエージェントシステムを実現します。
- ✔ データ処理とAIワークフローを統合
- ✔ 新しいコンテキストを使用してインテリジェントな意思決定を実現
- ✔ あらゆるモデル、ツール、データシステムと統合できます
- ✔ 業界唯一のデータストリーミングガバナンススイートでより速く、安全に反復処理を実行