シンプルでサーバーレスなストリーム処理
Confluent Cloud 上の Apache Kafka® と完全に統合された業界唯一のサーバーレス Apache Flink® サービスを使用して、3つの主要クラウドすべてで高品質かつ再利用可能なデータストリームを簡単に構築できます。
Confluent Platform for Apache Flink® はまた、オンプレミスおよびプライベートクラウドワークロードで一般利用可能となりました。詳細についてはこちらをご覧ください。
リアルタイムのユースケースにはリアルタイム処理が必要
企業内を流れるデータを変換、分析、処理することで、リアルタイムのデータ処理を可能にします。
- __データパイプラインの「シフトレフト」: __データが作成され次第クリーンアップして整形し、最新の信頼性が高く再利用可能なデータをデータウェアハウスまたはデータレイクに配信します。
-__リアルタイムマテリアライズドビュー :__下流のシステムやアプリケーションを段階的に更新されるリアルタイムユニバーサルデータプロダクトと同期させます。
- __従来のイベント処理 : __イベントが発生した時点でキャプチャして処理し、時間の経過とともにイベントを集約して分析し、傾向、パターン、異常を検出します。
ストリーム処理と AI を統合する
AI をデータストリームに直接導入することで、開発を簡素化します。Flink SQL と使い慣れた API を使用することで、リアルタイムの ML モデルから、最新のビジネスコンテキストを観察および推論し、その結果に基づいて行動する高度なイベントドリブン型ストリーミングエージェントまで、すべてを統合された本番環境対応のプラットフォーム上で構築できます。
AI Model Inference
Call any LLM for inference directly within stream processing jobs using familiar Flink SQL.
Real-time Embeddings
Generate vector embeddings for RAG in real time, from any model to any vector database, across any cloud platform
Built-in ML Functions
Use out-of-the-box Flink SQL functions for powerful, low-code anomaly detection and forecasting.
Streaming Agents
Go beyond models to build production-ready, event-driven agents that act on real-time business events, with native Flink support for orchestration, tool calling, and replayability.
フィルタリング、結合、充実化。
ストリーム処理のデファクトスタンダードである Flink を使用して、データストリームを簡単にフィルタリング、結合、充実化。
リアルタイム処理
リアルタイムのイベントに反応し、タイムリーな洞察を提供する低遅延のアプリケーションとパイプラインを強化
データの再利用性
一貫性のある再利用可能なデータストリームを下流のアプリケーションやシステムと広く共有
データの充実化
追加のコンテキストを使用してオンザフライでデータをキュレーション、フィルタリング、拡張し、完全性、正確性とコンプライアンスを向上
効率性
サイロ間の冗長な処理を回避することでリソースの使用率と費用対効果を向上
クラウドネイティブな体験
複雑なインフラストラクチャ管理が不要で、あらゆる規模で高性能かつ効率的なストリーム処理を実現
完全マネージド型
サーバーレス、SaaS ベースの体験を備えた Flink アプリケーションを簡単に開発し、運用負担なく即座に利用可能
柔軟なスケーラビリティ
オーバープロビジョニングなしで最も複雑なワークロードの要求を満たすために自動的にスケールアップ/スケールダウン
Infrastructure-as-code
プライベートクラウドとオンプレミスのワークロード向けに Kubernetes 上で Flink のデプロイを自動化
継続的なアップデート
自動アップグレードで常に最新のプラットフォームを使用して構築
Kafka と Flink を統合
エンタープライズ級の完全なデータストリーミングプラットフォームとして統合された Kafka と Flink を体験。
エンタープライズ級のセキュリティ
組み込みの ID およびアクセス管理、RBAC、詳細な監査ログによる安全なストリーム処理
ストリームガバナンス
スケーラブルなデータ互換性を可能にするユニバーサルデータ標準を定義・施行
モニタリング
Flink アプリケーションが確実かつ効率的に実行され、保守が容易であることを保証
Connectors
120種類以上のコネクターがあらかじめ組み込まれており、あらゆるアプリやシステムと接続可能
