GetAzureEventHub 2025.10.2.19¶
Bundle¶
org.apache.nifi | nifi-azure-nar
Description¶
Reçoit des messages provenant de Microsoft Azure Event Hubs sans suivi fiable des points de contrôle. Dans un environnement en cluster, les instances du processeur GetAzureEventHub fonctionnent indépendamment et tous les nœuds du cluster traitent tous les messages (sauf si le processeur fonctionne en mode primaire uniquement). ConsumeAzureEventHub propose l’approche recommandée pour la réception de messages en provenance d’Azure Event Hubs. Ce processeur crée un pool de threads pour les connexions Azure Event Hubs.
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Consumer Group |
Le nom du groupe de consommateurs à utiliser lors de l’extraction d’événements |
Nom du centre d’événements |
Nom de la source Azure Event Hubs |
Espace de noms du Hub d’événements |
Espace de noms des Azure Event Hubs préfixé au domaine du point de terminaison du bus de service |
Message Enqueue Time |
Un horodatage (ISO-8601 Instant) formaté sous la forme YYYY-MM-DDThhmmss. sssZ (2016-01-01T01:01:01.000Z) à partir duquel des messages auraient dû être mis en file d’attente dans le Hub d’événements pour commencer à lire les messages |
Partition Receiver Fetch Size |
Nombre d’événements qu’un récepteur doit aller chercher dans une partition Event Hubs avant de revenir. La valeur par défaut est 100. |
Partition Receiver Timeout |
Durée en millisecondes pendant laquelle un récepteur de partition doit attendre de recevoir la taille de l’extraction avant de revenir. La valeur par défaut est 60000. |
Point de terminaison du bus de service |
Pour prendre en charge les espaces de noms ne faisant pas partie du domaine windows.net par défaut. |
Shared Access Policy Key |
La clé de la politique d’accès partagé. Il est possible d’utiliser soit la clé primaire, soit la clé secondaire. |
Nom de la politique d’accès partagé |
Nom de la politique d’accès partagé. Cette politique doit être configurée avec Listen claims. |
Type de transport |
Type de transport du protocole avancé de mise en file d’attente des messages pour la communication avec les hubs d’événements Azure |
Use Azure Managed Identity |
Indique si l’identité gérée d’Azure VM/VMSS sera utilisée ou non |
service proxy-configuration |
Spécifie le Controller Service de configuration proxy pour les requêtes réseau proxy. |
Relations¶
Nom |
Description |
|---|---|
success |
Tout FlowFile reçu avec succès du centre d’événements sera transféré dans cette relation. |
Écrit les attributs¶
Nom |
Description |
|---|---|
eventhub.enqueued.timestamp |
Heure (en millisecondes depuis l’époque, UTC) à laquelle le message a été mis en file d’attente dans le hub d’événements |
eventhub.offset |
Le décalage au sein de la partition où le message a été stocké |
eventhub.sequence |
Le numéro de séquence Azure associé au message |
eventhub.name |
Le nom du hub d’événements d’où le message a été extrait |
eventhub.partition |
Le nom de la partition du concentrateur d’événements d’où le message a été extrait |
eventhub.property.* |
Les propriétés d’application de ce message. Exemple : « application » correspondrait à « eventhub.property.application » |