cKafka

Broker list

Spécifiez la liste des brokers de messages Kafka, sous la forme suivante hostname1:port1,hostname2:port2,hostname3:port3.

Client Id

Spécifiez une chaîne de caractères d'ID du client à passer au serveur lors de requêtes.

Topic

Saisissez un nom pour le topic du message dans le broker de messages.

GroupId

Saisissez l'ID du groupe de clusters Kafka Connect.

Receive Buffer (bytes)

Spécifiez la mémoire tampon de réception TCP à utiliser lors de la lecture des données. Si la valeur est -1, la valeur par défaut du système d'exploitation est utilisée.

Use Schema Registry

Pour plus d'informations concernant Schema Registry, consultez la documentation Confluent (en anglais).

Cette option est disponible si vous avez installé la mise à jour mensuelle 8.0.1-R2023-10 du Studio Talend ou une plus récente fournie par Talend. Pour plus d'informations, contactez votre administrateur ou administratrice.

Les options suivantes sont seulement disponibles lorsque le cKafka est utilisé en tant que producteur :

Partitioner

Saisissez le partitionneur qui détermine comment les données sont distribuées dans le cluster Kafka.

Serializer Class

Saisissez le nom de la classe du sérialiseur à utiliser.

Key Serializer Class

Saisissez le nom de la classe du sérialiseur de clé à utiliser.

Compression Codec

Sélectionnez le type de compression : NONE, GZIP, SNAPPY ou LZ4.

Les options suivantes sont seulement disponibles lorsque le cKafka est utilisé en tant que consommateur :

Auto Commit Enable

Cochez cette case pour commiter périodiquement l'offset de messages, en tâche de fond. Spécifiez la fréquence en millisecondes dans le champ Auto Commit Interval (ms) à laquelle les offsets consommateurs sont commités dans Kafka.

Auto Offset Reset

Sélectionnez la procédure à exécuter lorsqu'il n'y a pas d'offset initial dans Kafka ou si l'offset courant n'existe plus sur le serveur :

• EARLIEST : réinitialiser automatiquement l'offset au plus ancien ;

• LATEST : réinitialiser automatiquement l'offset au plus récent ;

• NONE : retourner une exception au consommateur si aucun offset précédent n'est trouvé pour le groupe de consommateurs.

Configurez les arguments facultatifs dans la table correspondante. Cliquez sur le bouton [+] autant de fois que nécessaire afin d'ajouter les arguments au tableau. Cliquez sur le champ de la valeur correspondante et saisissez une valeur. Consultez le site http://kafka.apache.org/documentation.html (en anglais) pour connaître les options disponibles.

SSL Key Password

Cliquez sur le bouton [...] et saisissez le mot de passe de la clé privée dans le fichier KeyStore, entre guillemets doubles.

SSL Keystore Location

Saisissez l'emplacement du fichier KeyStore.

SSL Keystore Password

Cliquez sur le bouton [...] et saisissez le mot de passe du fichier KeyStore, entre guillemets doubles. Cela est nécessaire uniquement si l'option SSL Keystore Location est configurée.

SSL Truststore Location

Saisissez l'emplacement du fichier TrustStore.

SSL Truststore Password

Cliquez sur le bouton [...] et saisissez le mot de passe, entre guillemets doubles, pour le fichier TrustStore.

SSL Cipher Suites

Saisissez la liste des suites cryptographiques. C'est une combinaison nommée d'authentification, chiffrement, MAC et algorithme d'échange de clés, utilisée pour négocier les paramètres de sécurité pour une connexion réseau utilisant un protocole TLS ou SSL. Par défaut, toutes les suites cryptographiques sont supportées.

SSL Endpoint Algorithm

Saisissez l'algorithme d'identification de l'endpoint pour valider le nom d'hôte du serveur à l'aide du certificat du serveur.

Kerberos Service Name

Saisissez le nom du Principal Kerberos que Kafka utilise pour s'exécuter.

Security Protocol

Sélectionnez le protocole à utiliser pour communiquer avec les brokers : Plaintext, SSL, SASL over Plaintext ou SASL over SSL.

Règle d'utilisation

Limitation

n/a