Propriétés du tKafkaCreateTopic Standard

Ces propriétés sont utilisées pour configurer le tKafkaCreateTopic s'exécutant dans le framework de Jobs Standard.

Le composant tKafkaCreateTopic 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

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.
Topic name	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. Note InformationsRemarque : Cette option est disponible si vous avez installé la mise à jour mensuelle 8.0.1-R2022-10 du Studio Talend ou une plus récente fournie par Talend. Pour plus d'informations, contactez votre administrateur ou administratrice.
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. Note InformationsRemarque : Cette option est disponible si vous avez installé la mise à jour mensuelle 8.0.1-R2022-10 du Studio Talend ou une plus récente fournie par Talend. Pour plus d'informations, contactez votre administrateur ou administratrice.

Paramètres avancés

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	Ajoutez les propriétés Kafka Admin nécessaires pour personnaliser cette table. Par exemple, vous pouvez utiliser cette table pour spécifier la configuration SSL en fournissant les propriétés suivantes et leurs valeurs : propriété "security.protocol" avec la valeur "SSL" propriété "ssl.truststore.location" avec la valeur "context.ssl_trustore_location" propriété "ssl.truststore.password" avec la valeur "context.ssl_password" 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)	Spécifiez le temps durant lequel le Studio Talend doit attendre, en millisecondes : 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. Note InformationsRemarque : Cette option est disponible si vous avez installé la mise à jour mensuelle 8.0.1-R2022-11 du Studio Talend ou une plus récente fournie par Talend. Pour plus d'informations, contactez votre administrateur ou administratrice.
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	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.
Limitation	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.

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.

Limitation

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.

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 – faites-le-nous savoir.

Laissez vos commentaires ici