Kafka3ConnectionService¶
Description¶
Fournit et gère les connexions aux Brokers Kafka pour les opérations de producteurs ou de consommateurs.
Propriétés¶
Dans la liste ci-dessous, les propriétés requises sont signalées par un astérisque (*). Les autres propriétés sont considérées comme facultatives. La table indique également les valeurs par défaut et précise si une propriété prend en charge le langage d’expression NiFi.
Nom d’affichage |
Nom d’API |
Valeur par défaut |
Valeurs autorisées |
Description |
|---|---|---|---|---|
Service contextuel SSL |
Service contextuel SSL |
Service supportant la communication SSL avec les brokers Kafka |
||
Temps d’attente de l’accusé de réception * |
ack.wait.time |
5 secondes |
Après l’envoi d’un message à Kafka, cette valeur indique le temps pendant lequel le service attendra une réponse de Kafka. Si Kafka n’accuse pas réception du message pendant cette période, le service lèvera une exception. |
|
Serveurs Bootstrap * |
bootstrap.servers |
Liste des serveurs d’amorçage Kafka, séparée par des virgules, au format host:port. Correspond à la propriété bootstrap.servers de Kafka |
||
Délai d’expiration du client * |
default.api.timeout.ms |
60 secondes |
Délai d’expiration par défaut pour les opérations du client Kafka. Mappé à Kafka default.api.timeout.ms. La propriété request.timeout.ms de Kafka est dérivée de la moitié du délai d’expiration configuré |
|
Niveau d’isolation des transactions * |
isolation.level |
read_committed |
|
Spécifie comment le service doit gérer les niveaux d’isolation des transactions lors de la communication avec Kafka. L’option uncommitted signifie que les messages seront reçus dès qu’ils sont écrits dans Kafka, mais seront récupérés même si le producteur annule la transaction. L’option committed configure le service pour ne recevoir que les messages dont la transaction du producteur a été validée. Cela peut cependant entraîner une certaine latence, car le consommateur doit attendre la fin complète de la transaction du producteur au lieu de récupérer les messages au fur et à mesure de leur disponibilité. Cela correspond au paramètre isolation.level de Kafka. |
Temps d’attente maximal pour les métadonnées * |
bloc.max.ms |
5 secondes |
Le temps que l’éditeur attendra pour obtenir des métadonnées ou pour que la mémoire tampon soit vidée pendant l’appel « send » avant d’échouer l’appel « send » entier. Correspond à la propriété Kafka max.block.ms |
|
Enregistrements du sondage max * |
max.poll.records |
10000 |
Nombre maximal d’enregistrements que Kafka doit renvoyer en une seule interrogation. |
|
Mécanisme SASL * |
sasl.mechanism |
GSSAPI |
|
Mécanisme SASL utilisé pour l’authentification. Correspond à la propriété sasl.mechanism du client Kafka |
Mot de passe SASL * |
sasl.password |
Mot de passe fourni avec le nom d’utilisateur configuré lors de l’utilisation des mécanismes PLAIN ou SCRAM SASL |
||
Nom d’utilisateur SASL * |
sasl.username |
Nom d’utilisateur fourni avec le mot de passe configuré lors de l’utilisation des mécanismes PLAIN ou SCRAM SASL |
||
Protocole de sécurité * |
security.protocol |
PLAINTEXT |
|
Protocole de sécurité utilisé pour communiquer avec les courtiers. Correspond à la propriété security.protocol du client Kafka |
Gestion de l’État¶
Ce composant ne stocke pas d’état.
Restreint¶
Cette composante n’est pas limitée.
Considérations relatives aux ressources du système¶
Ce composant ne précise pas les ressources du système à prendre en compte.