Propriétés du tKafkaCreateTopic Standard

Use an existing connection

Cochez cette case et sélectionnez le composant de connexion adéquat dans la liste Component list pour réutiliser les paramètres d'une connexion que vous avez déjà définie.

Version

Sélectionnez la version du cluster Kafka à utiliser.

Si vous avez installé la mise à jour mensuelle 8.0.1-R2024-02 du Studio Talend ou une plus récente fournie par Talend, les versions antérieures ou égales à Kafka 2.4.x sont dépréciées.

Action on topic

Sélectionnez comment créer un sujet :

• Create topic : crée un topic. Si le sujet existe déjà, le Job entier est arrêté.

• Create topic if not exists : crée un topic lorsque ce dernier n'existe pas. Si le sujet existe, le Job ignore la création et passe à l'étape suivante.

Saisissez le nom du topic à créer.

Broker list

Saisissez les adresses des nœuds du broker du cluster Kafka à utiliser.

L'adresse doit se présenter sous la forme suivante : hostname:port. Ces informations contiennent le nom et le port du nœud hébergeant dans le cluster Kafka.

Si vous devez spécifier plusieurs adresses, séparez-les à l'aide d'une virgule (,).

Replication factor

Saisissez le nombre de répliques à créer pour les logs des (l'ensemble des messages) partitions du topic.

Nombre de partitions

Saisissez le nombre de partitions à créer pour le topic.

Set topic retention time (ms)

Cochez cette case pour définir le temps maximal en millisecondes durant lequel le contenu du topic est retenu.

Lorsque ce temps est écoulé, le contenu est supprimé ou compacté, selon la politique définie dans la table Topic properties, dans la vue Advanced settings.

Use SSL/TLS

Cochez cette case pour activer la connexion chiffrée SSL ou TLS.

Set keystore

Cochez cette case pour activer la connexion chiffrée SSL ou TLS via un composant tSetKeystore.

Utilisez le composant tSetKeystore dans le même Job afin de spécifier les informations de chiffrement.

Cette case est disponible uniquement lorsque vous cochez la case Use SSL/TLS.

Zookeeper security is enabled

Cochez cette case pour vous connecter à un ZooKeeper sécurisé, pour améliorer la sécurité de votre cluster Kafka.

Pour plus d'informations concernant les fonctionnalités de sécurité ajoutées dans la version 0.9.0.0 de Kafka, consultez la documentation Kafka officielle (en anglais).

Cette propriété n'est pas disponible à partir de la version 2.4.x de Kafka.

Topic properties

Ajoutez les propriétés Kafka relatives au topic nécessaires pour personnaliser cette table.

Pour plus d'informations concernant les propriétés de niveau topic pouvant être définies dans cette table, consultez la section décrivant la configuration au niveau des topics dans la documentation officielle de Kafka (en anglais).

Kafka properties

Pour plus d'informations concernant les nouvelles propriétés Kafka Admin pouvant être définies dans cette table, consultez la section Admin Configs dans la documentation officielle de Kafka (en anglais).

Cette propriété est disponible uniquement lorsque vous utilisez la version 3.2.x de Kafka.

Timeout (ms)

• la connexion à Kafka, à partir de la version Kafka 2.4.x
• la session et la connexion à ZooKeeper, pour les versions antérieures à 2.2.1

La valeur par défaut est de 10000 millisecondes.

tStatCatcher Statistics

Cochez cette case pour collecter les métadonnées de traitement au niveau du Job ainsi qu'au niveau de chaque composant.

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.

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.

Règle d'utilisation

Ce composant est utilisé en standalone pour créer un topic pouvant être utilisé par les autres composants Kafka, dans d'autres Jobs ou sous-Jobs.

Du fait d'une incompatibilité de licence, un ou plusieurs Jar requis pour utiliser ce composant ne sont pas fournis. Vous pouvez installer les Jar manquants pour ce composant en cliquant sur le bouton Install dans l'onglet Component. Vous pouvez également trouver les JAR manquants et les ajouter dans l'onglet Modules de la perspective Integration de votre Studio Talend. Pour plus d'informations, consultez la page Installation de modules externes.