- Basé sur Rust et le runtime asynchrone Tokio, il offre d’excellentes performances et une faible latence. Il peut traiter rapidement des flux de données à grande échelle
- Prise en charge de diverses sources de données : Kafka, MQTT, HTTP, fichiers et autres sources d’entrée/sortie
- Filtrage et transformation des données en temps réel : prise en charge des requêtes SQL intégrées, de l’encodage/décodage JSON et Protobuf, ainsi que du traitement par lots
- Grâce à une conception modulaire, il est facile d’étendre de nouveaux composants d’entrée, de sortie et de traitement
- Possibilité d’ajouter des processeurs personnalisés pour prendre en charge un traitement de données sur mesure
- Une architecture de traitement asynchrone assure une grande stabilité
- En cas d’erreur, récupération automatique et retraitement possibles
- Utilisation de fichiers de configuration au format YAML, pour une configuration et un paramétrage simplifiés
- Tests et débogage rapides en local
Aucun commentaire pour le moment.