Interact | activityOrchestrator | receivers
Die Kategorie "activityOrchestrator | receivers" legt die Ereignisempfänger für die eingehende Gateway-Aktivität von Unica Interact fest.
Kategoriename
- Beschreibung
Der Name Ihres Empfängers.
Typ
- Beschreibung
- Der Typ des Empfängers. Sie können zwischen Kafka und Custom wählen. Für Custom müssen Sie eine Implementierung von iReceiver verwenden.Anmerkung: Wenn Sie Kafka in der Vorgängerversion verwendet haben, dann können Sie den Wert des Typs als Kafka in der Upgrade-Version einstellen.
Aktiviert
- Beschreibung
- Wählen Sie True aus, um den Empfänger zu aktivieren, oder wählen Sie False aus, um ihn zu inaktivieren.
className
- Beschreibung
- Diese Eigenschaft definiert den vollständig qualifizierten Klassennamen der Implementierung dieses Empfängers. Er wird nur verwendet, wenn der Typ Custom lautet. Für den Typ Kafka muss der Wert leer gelassen werden.
classPath
- Beschreibung
- Diese Eigenschaft definiert den URI der JAR-Datei, die die Implementierung dieses Empfängers enthält. Wird diese Eigenschaft leer gelassen, wird der Klassenpfad der hostenden Unica Interact-Anwendung verwendet. Er wird nur verwendet, wenn der Typ Custom lautet. Für den Typ Kafka muss der Wert leer gelassen werden.
- Interact | activityOrchestrator | receivers | Parameter Data
- Sie können Empfängerparameter (z.B. "queueManager" und "messageQueueName") hinzufügen, um Ihre Empfängerwarteschlange zu definieren.
- Obligatorische Parameter für das Abonnement von Nachrichten
- Standardmäßig unterstützt der Kafka-Server keinen Authentifizierungsmechanismus. Sie können den Kafka-Server starten, wenn der Authentifizierungsmechanismus deaktiviert ist. In diesem Fall können Sie den Parameter "Authentifizierung" auf den Wert "None" setzen. Die folgende Tabelle enthält die obligatorischen Parameter, die zum Abonnieren von Nachrichten erforderlich sind.
Parameter Zulässiger/Beispielparameterwert providerUrl < host>:<port> (Beispiel: localhost:9092)group.id Jede beliebige Zeichenfolge (Beispiel: InteractTMGateway) topic Jede beliebige Zeichenfolge (Beispiel: InteractTM) Authentifizierung Jede Zeichenfolge zookeeper.connect < host>:<port>(Beispiel: localhost:2181) - Authentifizierungsmechanismus
- Sie können Kafka verwenden, indem Sie verschiedene Authentifizierungsmechanismen aktivieren.
- Authentifizierung durch den SASL_PLAIN-Mechanismus
- Wenn Sie den SASL_PLAIN-Authentifizierungsmechanismus verwenden möchten, müssen Sie den Parameter "authentication" auf den Wert "Plain" zusammen mit den unterstützten Parametern setzen.
Wenn der SASL_PLAIN-Mechanismus unterstützt wird, müssen die folgenden Parameter angegeben werden.
- asmUserforMQAuth: Der Benutzername für die Anmeldung auf dem Server. Dieses ist erforderlich, wenn der Server eine Authentifizierung erzwingt.
- authDS: Das Kennwort, das dem Benutzernamen für die Anmeldung auf dem Server zugeordnet ist.
- Benutzername/Kennwort: Der Benutzername oder das Kennwort des Kafka-Servers, der in der JASS-Konfigurationsdatei konfiguriert ist.
Die folgende Tabelle enthält die für den SASL_PLAIN-Mechanismus erforderlichen Parameter.
Parameter Zulässige/Beispielparameterwerte Authentifizierung Normal asmUserforMQAuth Jede beliebige Zeichenfolge (Beispiel: test_user) authDS Jede beliebige Zeichenfolge (Beispiel: authDS) Benutzername Jede beliebige Zeichenfolge (Beispiel: test_user) Kennwort Jede beliebige Zeichenfolge (Beispiel: test-secret) Wenn der "Authentifizierungs"-Parameter "Plain" lautet, müssen Sie entweder asmUserforMQAuth/authDS oder Benutzername/-Kennwortparameter für die Authentifizierung verwenden.
Erstellen Sie die Datenquellen (authDS) im Abschnitt ''Benutzer'' in der Plattformkonfiguration. Einzelheiten zu den Datenquellen sind im folgenden Beispiel aufgeführt.
Datenquelle Benutzername Kennwort authDS test_user test-secret - Authentifizierung durch SSL-Mechanismus
- Um den SSL-Authentifizierungsmechanismus zu verwenden, müssen Sie den Parameter 'authentication' zusammen mit den unterstützten Parametern auf den Wert 'SSL' setzen.
Die folgenden Parameter sind zur Unterstützung des SSL-Mechanismus erforderlich.
- ssl.keystore.location: Die Adresse der Schlüsselspeicherdatei. Sie können sie für eine Zweiwege-Authentifizierung für den Client verwenden.
- ssl.truststore.location: Die Adresse der Truststore-Datei.
- SSLKeystoreDS: Der Name der Schlüsselspeicherdatenquelle, in der das Kennwort von SSL-Schlüsselspeicher gespeichert ist.
- SSLKeyDS: Der Name der Schlüsseldatenquelle, die das Paßwort des SSL-Schlüssels speichert.
- SSLTruststoreDS: Der Truststore-Datenquellenname, der das Kennwort von SSL-Truststore speichert.
Die folgende Tabelle enthält die unterstützten Parameter für den SSL-Mechanismus.
Parameter Zulässige/Beispielparameterwerte Authentifizierung SSL ssl.keystore.location Adresse des SSL-Schlüsselspeichers (Beispiel: C:/SSL/kafka.client.keystore.jks) ssl.truststore.location Adresse des SSL-Schlüsselspeichers (Beispiel: C:/SSL/kafka.client.truststore.jks) asmUserforMQAuth Jede beliebige Zeichenfolge (Beispiel: test_user) SSLKeystoreDS Jede beliebige Zeichenfolge (Beispiel: SSLKeystoreDS) SSLKeyDS Jede beliebige Zeichenfolge (Beispiel: SSLKeyDS) SSLTruststoreDS Jede beliebige Zeichenfolge (Beispiel: SSLTruststoreDS) Erstellen Sie die Datenquellen (SSLKeystoreDS, SSLKeyDS und SSLTruststoreDS) im Abschnitt Benutzer in der Plattformkonfiguration. Einzelheiten zu den Datenquellen sind im folgenden Beispiel aufgeführt.
Datenquelle Benutzername Kennwort SSLKeystoreDS Keystore keystore-secret SSLKeyDS Schlüssel key-secret SSLTruststoreDS Truststore truststore -secret Anmerkung: Der Client Keystore oder Truststore wird auf Produzenten- oder Konsumentenseite in der Interact-Anwendung benötigt (wo die Interact-Anwendung installiert ist). C:/SSL/kafka.client.keystore.jks und C:/SSL/kafka.client.truststore.jks sind die lokalen Speicherorte, an denen die Interact-Anwendung installiert ist. - Authentifizierung durch den SASL_SSL-Mechanismus
- Wenn Sie den SASL_SSL-Authentifizierungsmechanismus verwenden möchten, müssen Sie den Parameter "authentication" zusammen mit den unterstützten Parametern auf den Wert "SASL_SSL" setzen. Der SASL_SSL-Mechanismus besteht aus einer Kombination von SASL_PLAIN- und SSL-Mechanismen. Die folgende Tabelle enthält die unterstützten Parameter für den SASL_SSL-Mechanismus.
Parameter Zulässige/Beispielparameterwerte Authentifizierung SASL_SSL asmUserforMQAuth Jede beliebige Zeichenfolge (Beispiel: test_user) authDS Jede beliebige Zeichenfolge (Beispiel: authDS) Benutzername Jede beliebige Zeichenfolge (Beispiel: test_user) Kennwort Jede beliebige Zeichenfolge (Beispiel: test-secret) ssl.keystore.location Adresse des SSL-Schlüsselspeichers (Beispiel: C:/SSL/kafka.client.keystore.jks) ssl.truststore.location Adresse des SSL-Schlüsselspeichers (Beispiel: C:/SSL/kafka.client.truststore.jks) SSLKeystoreDS Jede beliebige Zeichenfolge (Beispiel: SSLKeystoreDS) SSLKeyDS Jede beliebige Zeichenfolge (Beispiel: SSLKeyDS) SSLTruststoreDS Jede beliebige Zeichenfolge (Beispiel: SSLTruststoreDS) Wenn der "Authentifizierungs"-Parameter "SASL_SSL" lautet, müssen Sie entweder asmUserforMQAuth/authDS oder Benutzername/Kennwort verwenden.
Erstellen Sie die Datenquellen (authDS, SSLKeystoreDS, SSLKeyDS und SSLTruststoreDS) im Abschnitt ''Benutzer'' in der Plattformkonfiguration. Einzelheiten zu den Datenquellen sind im folgenden Beispiel aufgeführt.
Datenquelle Benutzername Kennwort authDS Administrator admin-secret SSLKeystoreDS Keystore test1234 SSLKeyDS Schlüssel test1234 SSLTruststoreDS Truststore test1234 Anmerkung: Wenn Sie Datenquellen wie authDS, SSLKeystoreDS, SSLKeyDS oder SSLTruststoreDS im Konfigurationsparameter der Plattform angeben, müssen Sie auch den Parameter asmUserforMQAuth angeben.Der Client Keystore/Truststore wird auf Produzenten- oder Konsumentenseite in der Interact-Anwendung benötigt (wo die Interact-Anwendung installiert ist). C:/SSL/kafka.client.keystore.jks und C:/SSL/kafka.client.truststore.jks sind die lokalen Speicherorte, an denen die Interact-Anwendung installiert ist.
- Optionale Parameter zum Abonnement von Nachrichten
- enable.auto.commit bezeichnet die automatische Übertragung von Offsets mit einer Frequenz, die durch die Konfiguration "auto.commit.interval.ms" gesteuert wird. Der Wert von auto.commit.interval.ms darf 1000 nicht überschreiten, da das Abfrageintervall auf 1000 eingestellt ist. Der Wert von auto.commit.interval.ms darf den Wert des Abfrageintervalls nicht überschreiten.
Die folgende Tabelle enthält die optionalen Parameter zum Abonnieren von Nachrichten.
Parameter Standardwert Zulässige/Beispielparameterwerte enable.auto.commit true True, False auto.commit.interval.ms 200 Positive Ganzzahl - Optionale Thread-Verwaltungsparameter
- Die folgenden optionalen Parameter können für die Verwaltung von Threads verwendet werden.
- corePoolSize: Die Anzahl der Threads, die zur Überwachung des Kafka-Services im Pool verbleiben müssen.
- maxPoolSize: Die maximale Anzahl von Threads, die zur Überwachung des Kafka-Service im Pool verbleiben müssen.
- keepAliveTimeSecs: Die maximale Zeit, die die überschüssigen inaktiven Threads benötigen, um auf neue Tasks zu warten, bevor sie die Überwachung des Kafka-Service abbrechen, wenn die Anzahl der Threads größer ist als der Kern.
- queueCapacity Der Umfang der Warteschlange, die vom Thread-Pool zur Überwachung des Kafka-Service verwendet wird.
Die folgende Tabelle enthält die optionalen Parameter für die Verwaltung von Threads.
Parameter Standardwert Zulässige/Beispielparameterwerte corePoolSize 1 Positive Ganzzahl maxPoolSize 5 Positive Ganzzahl keepAliveTimeSecs 5 Positive Ganzzahl pqueueCapacity 100 Positive Ganzzahl - Optionale Zookeeper-Parameter
- Der folgende optionale Parameter kann für Zookeeper-Aktivitäten verwendet werden.
zookeeper.connection.timeout.ms: Die maximale Wartezeit für den Client, bis eine Verbindung mit Zookeeper hergestellt ist. Wenn nicht festgelegt, wird der Wert in "zookeeper.session.timeout.ms" verwendet.
Die folgende Tabelle enthält die optionalen Parameter für die Zookeeper-Aktivitäten.
Parameter Standardwert Zulässiger/Beispielparameterwert zookeeper.connection.timeout.ms 6000 Positive Ganzzahl - Optionale Parameter für die Erstellung von Themen
- Die folgenden optionalen Parameter können für die Erstellung von Themen verwendet werden.
- num.partitions: Die Anzahl der Partitionen für das Thema Offset-Commit.
- replication.factor: Der Replizierungsfaktor zum Ändern von Protokoll- und Repartitionsthemen, die von der Stream-Verarbeitungsanwendung erstellt wurden.
Die folgende Tabelle enthält die optionalen Parameter für die Erstellung von Themen.
Parameter Standardwert Zulässige/Beispielparameterwerte num.partitions 1 Positive Ganzzahl replication.factor 1 Positive Ganzzahl