ArkFlow - 高性能な Rust ストリーム処理エンジン
(github.com/chenquan)- Rust と Tokio の非同期ランタイム基盤により、優れた性能と低レイテンシを実現。大規模なデータストリームを高速に処理可能
- 多様な データソース をサポート: Kafka、MQTT、HTTP、ファイル、およびその他の入出力ソース
- リアルタイムのデータフィルタリングと変換: 組み込み SQL クエリ、JSON および Protobuf のエンコード/デコード対応、バッチ処理機能を提供
- モジュール型設計により、新しい入力、出力、および処理コンポーネントを容易に拡張可能
- ユーザー定義プロセッサを追加して、カスタムデータ処理に対応
- 非同期ベースの処理構造により高い安定性を提供
- エラー発生時には自動復旧および再処理が可能
- YAML 形式の設定ファイルを使用することで、構成と設定が容易
- ローカルで迅速にテストおよびデバッグ可能
まだコメントはありません。