Propriétés du tKafkaCommit Standard
Ces propriétés sont utilisées pour configurer le tKafkaCommit s'exécutant dans le framework de Jobs Standard.
Le composant tKafkaCommit Standard appartient à la famille Internet.
Le composant de ce framework est disponible dans tous les produits Talend avec Big Data et dans Talend Data Fabric.
Basic settings
|
Commit offsets from |
Sélectionnez le composant tKafkaInput duquel les messages consommés sont commités. |
Advanced settings
|
tStatCatcher Statistics |
Cochez cette case pour collecter les métadonnées de traitement au niveau du Job ainsi qu'au niveau de chaque composant. |
Variables globales
|
ERROR_MESSAGE |
Message d'erreur généré par le composant lorsqu'une erreur survient. Cette variable est une variable After et retourne une chaîne de caractères. |
Variables globales
|
ERROR_MESSAGE |
Message d'erreur généré par le composant lorsqu'une erreur survient. Cette variable est une variable After et retourne une chaîne de caractères. |
Utilisation
|
Règle d'utilisation |
Même si le tKafkaCommit peut être utilisé comme composant de fin dans le flux d'un sous-Job ou être appelé indépendamment comme sous-Job, il est généralement utilisé en standalone pour commiter un lot d'offsets en une seule fois. Si vous avez besoin de commiter des lots d'offsets régulièrement, il est recommandé d'utiliser la fonctionnalité d'auto-commit dans le tKafkaInput. |
Cette page vous a-t-elle aidé ?
Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – dites-nous comment nous améliorer !