Support des flux temps réel
Vos bus d'événements et files de messages deviennent des sources traitées à la volée. iD4Connect consomme Kafka, MQTT ou AMQP en continu, sans accumuler les messages avant de les traiter.
Traiter l'événement sans file d'attente
Un flux événementiel n'a de valeur que s'il est traité au rythme où il arrive. Le déverser d'abord dans un stockage pour l'analyser ensuite introduit une latence qui ruine l'intérêt du temps réel. iD4Connect consomme le flux et agit sur chaque message en vol.
De la source à la destination, en un seul passage
Abonnement au flux
iD4Connect s'abonne à vos sujets Kafka, files MQTT, AMQP ou Kinesis, et consomme les messages dès leur publication. L'ordre et le positionnement (offset) sont respectés.
Traitement message par message
Chaque événement est décodé, transformé et enrichi individuellement, sans mise en tampon préalable. La contre-pression (backpressure) régule le débit face aux pics.
Publication en continu
Les événements traités sont republiés vers votre destination (autre flux, base, service) au fil de l'eau. La latence de bout en bout reste de l'ordre de la milliseconde.
Ce que cette fonctionnalité vous apporte
Bus d'événements
Kafka, MQTT, AMQP et Kinesis sont consommés nativement, en tant que source comme en tant que destination.
Ordre garanti
Le suivi des offsets préserve l'ordre des événements et la reprise après interruption.
Contre-pression
Le débit s'adapte automatiquement aux pics pour éviter la perte de messages.
Latence minimale
Le traitement en vol maintient une latence de bout en bout très faible.
Bénéfices
- Réaction à l'événement en quelques millisecondes.
- Aucune accumulation de messages avant traitement.
- Ordre et reprise préservés après incident.
- Débit régulé face aux pics de charge.
En pratique
Une plateforme IoT industrielle émet des relevés de capteurs sur un bus Kafka à haute fréquence. Votre architecte data veut détecter les dépassements de seuil sans latence. iD4Connect consomme le sujet Kafka, évalue chaque relevé en transit contre vos règles et republie immédiatement les alertes vers le service de supervision. Aucun relevé n'est stocké avant décision et l'alerte part dans la milliseconde suivant le dépassement.
Questions fréquentes
Quels systèmes de messagerie sont pris en charge ?
Kafka, MQTT, AMQP (RabbitMQ) et Kinesis figurent parmi les flux consommés et produits nativement.
Que se passe-t-il en cas de pic de messages ?
La contre-pression régule la consommation et le suivi des offsets garantit qu'aucun message n'est perdu ni traité deux fois.
L'ordre des événements est-il conservé ?
Oui, au sein de chaque partition : le positionnement est suivi pour préserver l'ordre et permettre la reprise.
Orchestrez vos données en transit, sans stockage
iD4Connect connecte, transforme et distribue vos flux en temps réel. Souverain, on-premise, cloud ou edge.
Demandez une démo