Ces propriétés sont utilisées pour configurer le tKafkaCommit s'exécutant dans le framework de Jobs Spark Streaming.
Le composant tKafkaCommit Spark Streaming appartient à la famille Messaging.
Ce composant est disponible dans Talend Real Time Big Data Platform et dans Talend Data Fabric.
Basic settings
|
Commit offsets from |
Sélectionnez le composant tKafkaInput duquel les messages consommés sont commités. |
Utilisation
|
Règle d'utilisation |
Pour utiliser le tKafkaCommit, la case Auto-commit offests de la vue Basic settings du tKafkaInput doit être décochée. Ce composant est supporté avec Spark v2.0 et ultérieures, en mode Spark Local. Il est généralement utilisé en standalone pour commiter un lot d'offsets. Ce composant, ainsi que les composants Spark Streaming de la Palette à laquelle il appartient, s'affichent uniquement lorsque vous créez un Job Spark Streaming. |