Paramètres spécifiques aux composants pour le tKafkaOutput - Cloud - 8.0

Guide de référence des scripts de Jobs Talend
Version
Cloud
8.0
Language
Français
Product
Talend Big Data
Talend Big Data Platform
Talend Cloud
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
Module
Studio Talend
Talend CommandLine
Content
Création et développement > Création de Jobs
Last publication date
2024-02-22

Le tableau suivant présente les fonctions et paramètres des scripts de Jobs que vous pouvez définir dans la fonction setSettings {} du composant.

Fonction/paramètre Description Obligatoire ?

USE_EXISTING_CONNECTION

Configurez ce paramètre à true et spécifiez le nom du composant de connexion associé, à l'aide du paramètre CONNECTION, afin de réutiliser les informations de la connexion précédemment définie.

Non

KAFKA_VERSION

Spécifiez la version du cluster Kafka à utiliser. Les valeurs acceptées sont :

  • KAFKA_0_10_0_1
  • KAFKA_0_9_0_1
  • KAFKA_0_8_2_0

Oui

BROKER_LIST

Spécifiez les adresses des nœuds de brokers du cluster Kafka à utiliser, au format "\"host1:port1,host2:port2,...\"".

Oui

KAFKA_TOPIC

Spécifiez le nom du topic duquel ce composant reçoit le flux des messages.

Oui

COMPRESS

Configurez ce paramètre à true afin de compresser les données de sortie. Spécifiez le format de compression à l'aide du paramètre COMPRESSION :

  • GZIP : effectue une compression Gzip sur la sortie.
  • SNAPPY : effectue une compression Snappy sur la sortie.

Non

USE_HTTPS

Configurez ce paramètre à true pour activer le chiffrement SSL ou TLS de la connexion et utilisez le paramètre HTTPS_SETTING afin de spécifier quel composant tSetKeystore vous utilisez pour les informations de chiffrement.

Ce paramètre fonctionne uniquement lorsque la version du cluster Kafka est Kafka 0.9.2.1 ou supérieure.

Non

USE_KRB

Si le cluster Kafka à utiliser utilise la sécurité Kerberos, configurez ce paramètre à true et utilisez les paramètres suivants afin de définir les informations relatives à la sécurité :

  • JAAS_CONF : spécifiez le chemin d'accès au fichier de configuration JAAS à utiliser dans le Job pour vous authentifier à Kafka en tant que client.

  • KRB_SERVICE_NAME : spécifiez la partie primaire du Principal Kerberos définie pour les brokers lors de la création du cluster de brokers.

    Par exemple, pour le Principal kafka/kafka1.hostname.com@EXAMPLE.COM, la valeur de ce paramètre est kafka.

  • SET_KINIT_PATH : Kerberos utilise un chemin par défaut pour son exécutable kinit. Si vous avez modifié ce chemin, configurez ce paramètre à true et utilisez le paramètre KINIT_PATH afin de spécifier le chemin d'accès personnalisé.

  • SET_KRB5_CONF : Kerberos utilise un chemin par défaut vers son fichier de configuration, krb5.conf (ou krb5.ini sous Windows) pour Kerberos 5, par exemple. Si vous avez modifié ce chemin, configurez ce paramètre à true et utilisez KRB5_CONF afin de spécifier le chemin d'accès personnalisé au fichier de configuration Kerberos.

Ce paramètre fonctionne uniquement lorsque la version du cluster Kafka est Kafka 0.9.2.1 ou supérieure.

Non

KAFKA_PRODUCER_PROPERTIES {}

Si vous devez utiliser une configuration personnalisée pour le producteur Kafka, ajoutez dans cette fonction un ou plusieurs jeu(x) des paramètres suivants afin de spécifier la (les) propriété(s) à personnaliser. Lors de l'exécution, les propriétés personnalisées vont écraser les propriétés utilisées par le Studio Talend.

  • PROPERTY : saisissez le nom de la propriété.
  • VALUE : saisissez la nouvelle valeur de la propriété.

Non

TSTATCATCHER_STATS

Configurez ce paramètre à true pour rassembler les métadonnées de traitement au niveau du Job ainsi qu'un niveau des composants.

Par défaut, ce paramètre est configuré à false.

Non

LABEL

Utilisez ce paramètre pour spécifier un libellé textuel pour le composant.

Non