Interact | triggeredMessage | répartiteurs | <nomRépartiteur> | Données de paramètre

Vous pouvez choisir entre trois types de répartiteurs. InMemoryQueue est le répartiteur interne d'Unica Interact. Custom est utilisé pour Kafka. JMSQueue est utilisé pour se connecter à un fournisseur JMS via JNDI. Kafka est distribué en tant que plateforme de diffusion, qui est utilisée pour publier et s'abonner aux flux d'enregistrements.

category name

Description

Cette propriété définit le nom de ce paramètre. Ce nom doit être unique parmi tous les paramètres de ce répartiteur.

valeur

Description

Cette propriété définit les paramètres, au format de paires nom/valeur, requis par ce répartiteur.

Remarque : Tous les paramètres sont sensibles à la casse et doivent être entrés comme indiqué ici.

Si le type est InMemoryQueue, le paramètre ci-après est pris en charge.

• queueCapacity : Facultatif. Nombre maximal d'offres en attente de répartition dans la file d'attente. Si cette propriété est spécifiée, il doit s'agir d'un entier positif. Si elle ne l'est pas ou qu'elle n'est pas valide, la valeur par défaut (1 000) est utilisée.

Si le type est Custom, les paramètres ci-après sont pris en charge.

• providerUrl : <nomhôte>:port (sensible à la casse)
• queueManager : nom du gestionnaire de files d'attente créé sur le serveur Kafka.
• messageQueueName : nom de la file d'attente de messages créée sur le serveur Kafka.
• enableConsumer : cette propriété doit être définie sur true.
• asmUserforMQAuth : nom d'utilisateur permettant de se connecter au serveur. Ce nom est requis si le serveur applique l'authentification. Sinon, il ne doit pas être spécifié.
• authDS : mot de passe associé au nom d'utilisateur permettant de se connecter au serveur. Ce nom est requis si le serveur applique l'authentification. Sinon, il ne doit pas être spécifié.

Si le type est JMSQueue, le paramètre ci-après est pris en charge.

• providerUrl : adresse URL du fournisseur JNDI (sensible à la casse).
• connectionFactoryJNDI : nom JNDI de la fabrique de connexions JMS.
• messageQueueJNDI : nom JNDI de la file d'attente JMS vers laquelle les messages déclenchés sont envoyés et de laquelle ils sont extraits.
• enableConsumer : Cette propriété indique si un consommateur de ces messages déclenchés doit être lancé dans Unica Interact. cette propriété doit être définie sur true. Si elle ne l'est pas, la valeur par défaut (false) est utilisée.
• initialContextFactory : nom complet de la classe de fabrique de contexte initial JNDI. Si vous utilisez WebLogic, la valeur de ce paramètre doit être weblogic.jndi.WLInitialContextFactory.

Si le type est Kafka, les paramètres ci-après sont pris en charge.

• providerUrl : une liste de paires hôte/port à utiliser pour établir la connexion initiale avec le cluster Kafka. Cette liste doit avoir la forme de host1:port1,host2:port2,....
• topic: Une rubrique est un nom de catégorie ou de flux dans laquelle les messages sont stockés et publiés. Tous les messages Kafka sont organisés en rubriques. Si vous devez envoyer un message, vous pouvez l'envoyer vers une rubrique spécifique et si vous souhaitez lire un message, vous pouvez le faire depuis une rubrique spécifique. Les applications producteurs écrivent des données à des rubriques et les applications clients lisent à partir des rubriques. Le nom de la rubrique doit contenir un caractère alphanumérique ASCII, '.', '_' et des caractères '-'. En raison des limitations au niveau des noms de rubrique, vous pouvez utiliser des rubriques avec un point ('.') ou un trait de soulignement ('_'). La longueur maximale du nom d'une rubrique peut aller jusqu'à 255 caractères. Par exemple, si vous créez ou fournissez un nom de rubrique "InteractTM_1", et si vous créez une rubrique telle que "InteractTM.1", l'erreur suivante est générée. "Topic InteractTM.1 collides with existing topics: InteractTM _1.”
• group.id : Indique le nom du groupe de consommateurs auquel appartient un consommateur Kafka.
• zookeeper.connect : Spécifie la chaîne de connexion ZooKeeper sous forme de hostname:port, où le nom d'hôte et le port sont l'hôte et le port d'un serveur ZooKeeper.
• Authentification  : Les utilisateurs peuvent utiliser Kafka en activant différents mécanismes d'authentification.

Paramètres obligatoires pour publier et s'abonner à des messages

Par défaut, le serveur Kafka ne prend en charge aucun mécanisme d'authentification. Les utilisateurs peuvent démarrer le serveur Kafka en supposant que le mécanisme d'authentification est désactivé. Dans ce cas, les utilisateurs peuvent définir le paramètre "authentification" avec la valeur "Aucune".

Tableau 1. Paramètres obligatoires pour publier des messages

Paramètres	Valeurs de paramètre autorisées/d'exemple
providerUrl	<host>:<port> (example : localhost:9092)
topic	N'importe quelle chaîne (exemple : InteractTM)
authentification	none | Plain | SSL | SASL_SSL
zookeeper.connect	<host>:<port> (example : localhost:2181)

Tableau 2. Paramètres obligatoires pour s'abonner à des messages

Paramètres	Valeur de paramètre autorisée/d'exemple
providerUrl	<host>:<port> (example : localhost:9092)
group.id	N'importe quelle chaîne (exemple : InteractTMGateway)
topic	N'importe quelle chaîne (exemple : InteractTM)
authentification	none | Plain | SSL | SASL_SSL
zookeeper.connect	<host>:<port> (example : localhost:2181)

Mécanisme d'authentification

Vous pouvez utiliser Kafka en activant différents mécanismes d'authentification.

Authentification par mécanisme SASL_PLAIN

Si vous avez besoin d'utiliser le mécanisme d'authentification SASL_PLAIN, vous devez définir le paramètre "authentification" avec la valeur "Simple" en plus des paramètres pris en charge.

Les paramètres suivants sont requis si le mécanisme SASL_PLAIN est pris en charge.

• asmUserforMQAuth : nom d'utilisateur permettant de se connecter au serveur. Ce nom est requis si le serveur applique l'authentification.
• authDS : mot de passe associé au nom d'utilisateur permettant de se connecter au serveur.
• Nom d'utilisateur/Mot de passe Le nom d'utilisateur ou le mot de passe du serveur Kafka configuré dans le fichier de configuration JASS.

Le tableau suivant présente les paramètres requis pour le mécanisme SASL_PLAIN.

Paramètres	Valeurs de paramètre autorisées/d'exemple
authentification	Normal
asmUserforMQAuth	N'importe quelle chaîne (exemple : test_user)
authDS	N'importe quelle chaîne (exemple : authDS)
nom utilisateur	N'importe quelle chaîne (exemple : test_user)
mot de passe	N'importe quelle chaîne (exemple : test-secret)

Si le paramètre "authentification" est "Simple", vous devez utiliser des paramètres asmUserforMQAuth/authDS ou nom d'utilisateur/mot de passe pour l'authentification.

Créez les sources de données (authDS) dans la section Utilisateur de la configuration de plateforme. Reportez-vous à l'exemple suivant pour obtenir les détails des sources de données.

Source de données	Nom d'utilisateur	Mot de passe
authDS	test_user	test-secret

Authentification par mécanisme SSL

Pour utiliser le mécanisme d'authentification SSL, vous devez définir le paramètre "authentification" avec la valeur "SSL" en plus des paramètres pris en charge.

Les paramètres suivants sont requis pour prendre en charge le mécanisme SSL.

• ssl.keystore.location : L'emplacement du fichier du magasin de clés. Vous pouvez l'utiliser pour une authentification bidirectionnelle pour le client.
• ssl.truststore.location : L'emplacement du fichier du magasin de certification.
• SSLKeystoreDS : Le nom de la source de données du magasin de clés qui stocke le mot de passe du magasin de clés SSL.
• SSLKeyDS : Le nom de la source de données de clés qui stocke le mot de passe de la clé SSL.
• SSLTruststoreDS : Le nom de la source de données du magasin de certification qui stocke le mot de passe du magasin de certification SSL.

Le tableau suivant contient les paramètres pris en charge pour le mécanisme SSL.

Paramètres	Valeurs de paramètre autorisées/d'exemple
authentification	SSL
ssl.keystore.location	SSL Keystore location (example: C:/SSL/kafka.client.keystore.jks)
ssl.truststore.location	SSL Keystore location (example: C:/SSL/kafka.client. truststore.jks)
asmUserforMQAuth	N'importe quelle chaîne (exemple : test_user)
SSLKeystoreDS	N'importe quelle chaîne (exemple : SSLKeystoreDS)
SSLKeyDS	N'importe quelle chaîne (exemple : SSLKeyDS)
SSLTruststoreDS	N'importe quelle chaîne (exemple : SSLTruststoreDS)

Créez les sources de données (SSLKeystoreDS, SSLKeyDS et SSLTruststoreDS) dans la section Utilisateur de la configuration de plateforme. Reportez-vous à l'exemple suivant pour obtenir les détails des sources de données.

Source de données	Nom d'utilisateur	Mot de passe
SSLKeystoreDS	fichier de clés	keystore-secret
SSLKeyDS	key	key-secret
SSLTruststoreDS	magasin de clés de confiance	truststore -secret

Remarque : Le magasin de clés ou le magasin de certification client est requis côté Producteur ou Consommateur dans l'application Unica Interact (où l'application Interact est installée). C:/SSL/kafka.client.keystore.jks et C:/SSL/kafka.client.truststore.jks sont les emplacements locaux, où l'application Interact est installée.

Authentication by SASL_SSL mechanism

If you require to use the SASL_SSL authentication mechanism, then you must set the parameter "authentication" with value "SASL_SSL" along with its supported parameters. SASL_SSL mechanism is the combination of SASL_PLAIN and SSL mechanisms. The following table includes the supported parameters for SASL_SSL mechanism.

Paramètres	Valeurs de paramètre autorisées/d'exemple
authentification	SASL_SSL
asmUserforMQAuth	N'importe quelle chaîne (exemple : test_user)
authDS	N'importe quelle chaîne (exemple : authDS)
nom utilisateur	N'importe quelle chaîne (exemple : test_user)
mot de passe	N'importe quelle chaîne (exemple : test-secret)
ssl.keystore.location	SSL Keystore location (example: C:/SSL/kafka.client.keystore.jks)
ssl.truststore.location	SSL Keystore location (example: C:/SSL/kafka.client. truststore.jks)
SSLKeystoreDS	N'importe quelle chaîne (exemple : SSLKeystoreDS)
SSLKeyDS	N'importe quelle chaîne (exemple : SSLKeyDS)
SSLTruststoreDS	N'importe quelle chaîne (exemple : SSLTruststoreDS)

If the "authentication" parameter is "SASL_SSL", you must either use asmUserforMQAuth/authDS or username/password.

Créez les sources de données (authDS, SSLKeystoreDS, SSLKeyDS et SSLTruststoreDS) dans la section Utilisateur de la configuration de plateforme. Reportez-vous à l'exemple suivant pour obtenir les détails des sources de données.

Source de données	Nom d'utilisateur	Mot de passe
authDS	admin	admin-secret
SSLKeystoreDS	fichier de clés	test1234
SSLKeyDS	key	test1234
SSLTruststoreDS	magasin de clés de confiance	test1234

Remarque : Si vous fournissez des sources de données telles qu'authDS, SSLKeystoreDS, SSLKeyDS ou SSLTruststoreDS dans le paramètre de configuration de plateforme, vous devez également fournir le paramètre asmUserforMQAuth.

Le magasin de clés/magasin de certification client est requis côté Producteur/Consommateur dans l'application Interact (où l'application Unica Interact est installée). C:/SSL/kafka.client.keystore.jks et C:/SSL/kafka.client.truststore.jks sont les emplacements locaux, où l'application Interact est installée.

Paramètres facultatifs pour publier des messages

La table suivante inclut les paramètres facultatifs requis pour publier des messages.

• acks : La configuration acks contrôle les critères selon lesquels les requêtes sont considérées comme terminées. Le paramètre "tous" entraîne le blocage de la validation complète de l'enregistrement.
• retries : En cas d'échec de la requête, le producteur peut réessayer. Etant donné que le nombre de nouvelles tentatives spécifié est défini sur 0, aucune nouvelle tentative n'est autorisée. L'activation des nouvelles tentatives peut donner lieu à des doublons.
• batch.size : La taille de lot par défaut est exprimée en octets, lorsque plusieurs enregistrements sont regroupés en lots et envoyés vers une partition.
• linger.ms : Le producteur attend la fin du délai donné permettant d'envoyer d'autres enregistrements, afin de pouvoir regrouper les enregistrements envoyés.
• buffer.memory : Le nombre total d'octets de mémoire que le producteur peut utiliser afin de mettre des enregistrements en mémoire tampon, qui attendent d'être envoyés au serveur.

La table suivante inclut les paramètres facultatifs requis pour publier des messages.

Paramètres	Valeur par défaut	Valeurs de paramètre autorisées/d'exemple
acks	1	0, 1, all
retries	3	entier non négatif
batch.size	16384	Nombre entier positif
linger.ms	0	entier non négatif
buffer.memory	33554432	Nombre entier positif

Paramètres facultatifs pour publier des messages

enable.auto.commit signifie que des décalages sont réalisés automatiquement avec une fréquence contrôlée par la configuration "auto.commit.interval.ms". La valeur d'auto.commit.interval.ms ne doit pas dépasser 1 000, étant donné que l'intervalle d'interrogation est défini sur 1 000. La valeur d'auto.commit.interval.ms ne doit pas dépasser la valeur de l'intervalle d'interrogation.

La table suivante inclut les paramètres facultatifs pour s'abonner à des messages.

Paramètres	Valeur par défaut	Valeurs de paramètre autorisées/d'exemple
enable.auto.commit	true	True, False
auto.commit.interval.ms	200	Nombre entier positif

Paramètres de gestion de threads facultatifs

Les paramètres facultatifs suivants peuvent être utilisés pour la gestion de threads.

• corePoolSize : Le nombre de threads à conserver dans le pool pour surveiller le service Kafka.
• maxPoolSize : Le nombre maximum de threads à conserver dans le pool pour surveiller le service Kafka.
• keepAliveTimeSecs : Le laps de temps maximum pendant lequel les unités d'exécution inactives en trop attendent que les nouvelles tâches prennent fin en vue de surveiller le service Kafka, lorsque le nombre de threads est supérieur au core.
• queueCapacity : La taille de la fille d'attente utilisée par le pool de threads pour surveiller le service Kafka.

Le tableau suivant contient les paramètres facultatifs pour la gestion de threads.

Paramètres	Valeur par défaut	Valeurs de paramètre autorisées/d'exemple
corePoolSize	1	Nombre entier positif
maxPoolSize	5	Nombre entier positif
keepAliveTimeSecs	5	Nombre entier positif
queueCapacity	100	Nombre entier positif

Paramètres Zookeeper optionnels

Les paramètres facultatifs suivants peuvent être utilisés pour des activités Zookeeper.

zookeeper.connection.timeout.ms : Le laps de temps maximum pendant lequel le client attend pour établir une connexion avec Zookeeper. S'ils ne sont pas définis, la valeur de "zookeeper.session.timeout.ms" est utilisée.

Le tableau suivant contient les paramètres facultatifs pour les activités Zookeeper.

Paramètres	Valeur par défaut	Valeur de paramètre autorisée/d'exemple
zookeeper.connection.timeout.ms	6000	Nombre entier positif

Paramètres facultatifs pour créer une rubrique

Les paramètres facultatifs suivants peuvent être utilisés pour créer une rubrique.

• num.partitions : Le nombre de partitions pour la rubrique de validation de décalage.
• replication.factor : Le facteur de réplication pour modifier les rubriques de journal et les rubriques de répartition créé par l'application de traitement des flots.

Le tableau suivant contient les paramètres facultatifs pour la création de rubrique.

Paramètres	Valeur par défaut	Valeurs de paramètre autorisées/d'exemple
num.partitions	1	Nombre entier positif
replication.factor :	1	Nombre entier positif