Propriétés du tKafkaCommit pour Apache Spark Streaming - 7.3

Kafka

Version
7.3
Language
Français (France)
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka
Gouvernance de données > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka
Qualité et préparation de données > Systèmes tiers > Composants Messaging (Intégration) > Composants Kafka

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.