Apache Kafka Publisher

Der Adapter ermöglicht es, Nachrichten zu einem bestimmten Apache Kafka Topic zu veröffentlichen.

Eigenschaften (Properties)

Operation

Definiert die vom Adapter ausgeführte Operation.

Mögliche Werte:

Publish: Veröffentlicht eine Nachricht zu einem bestimmten Topic, die in einem XML-Input angegeben ist.

Parameter

`Adapter`	Adapter-Hauptklasse (nicht verändern!) Mögliche Werte: de.softproject.integration.adapter.apachekafka.ApacheKafkaPublisherAdapter: Hauptklasse (Standard)
`trustStorePath`	Definiert, wo sich der zu verwendende Trust Store befindet.
`trustStorePassword`	Definiert, welches Passwort für den Trust Store verwendet wird.
`keyStorePath`	Definiert, wo sich der zu verwendende Key Store befindet.
`keyStorePassword`	Passwort für den Key Store
`privateKeyPassword`	Passwort des Private Key in der Key-Store-Datei
`username`	Benutzername zur SASL/PLAIN-Authentifizierung am Kafka-Server Wenn Sie diesen Parameter verwenden, werden die Konfigurationseigenschaften `sasl.mechanism = PLAIN` und `security.protocol = SASL_SSL` gesetzt.
`password`	Password zur SASL/PLAIN-Authentifizierung am Kafka-Server Wenn Sie diesen Parameter verwenden, werden die Konfigurationseigenschaften `sasl.mechanism = PLAIN` und `security.protocol = SASL_SSL` gesetzt.
`clusterId`	ID des Clusters, in dem die Nachricht veröffentlicht wird Mögliche Werte: Cluster-ID Die ID des Clusters kann in der Datei `apachekafka-config.xml` gefunden werden. Sie befindet sich im Attribut `id` des Elements `Cluster`.
`clientId`	ID des Clients, mit dem die Nachricht veröffentlicht wird Mögliche Werte: Client-ID Die ID des Clients kann in der Datei `apachekafka-config.xml` gefunden werden. Sie befindet sich im Attribut `id` des Elements `Client`.
`topic`	Name des Topics, in dem die Nachricht veröffentlicht wird Mögliche Werte: Zeichenkette aus alphanumerischen ASCII-Zeichen, `.` (Punkt), `_` (Unterstrich) und `-` (Bindestrich)
`messageDataType`	Datentyp der Nachricht(en), die veröffentlicht werden. Mögliche Werte: `BYTES`: Base64-kodierter Wert `BYTEARRAY`: Base64-kodierter Wert `DOUBLE`: Gleitkommazahl `FLOAT`: Gleitkommazahl `INTEGER`: Ganzzahl `LONG`: Ganzzahl `SHORT`: Ganzzahl `STRING` (Standard): Zeichenkette `UUID`: Java UUID In einem Topic können Nachrichten mit verschiedenen Datentypen veröffentlicht werden. Um die Nachrichten mit dem Apache Kafka Subscriber Adapter zu lesen, muss der Datentyp bekannt und korrekt eingestellt sein. Beispielsweise kann eine Nachricht vom Datentyp `STRING` nicht mit der Datentyp-Einstellung `LONG` gelesen werden. Daher sollten alle Nachrichten in einem Topic vom selben Datentyp sein.
`keyDataType`	Datentyp des Schlüssels Mögliche Werte: `NONE` (Standard): Dieser Wert wird verwendet, wenn kein Schlüssel definiert ist. `BYTES`: Base64-kodierter Wert `BYTEARRAY`: Base64-kodierter Wert `DOUBLE`: Gleitkommazahl `FLOAT`: Gleitkommazahl `INTEGER`: Ganzzahl `LONG`: Ganzzahl `SHORT`: Ganzzahl `STRING` (Standard): Zeichenkette `UUID`: Java UUID Beispielhafte Schlüssel-Definition XML `<Messages> <Message key="055b93a8-4eda-41d8-8b73-b852a1d4da1e">055b93a8-4eda-41d8-8b73-b852a1d4da1e</Message> </Messages>` Folgende vier Fälle können unterschieden werden: Ein Schlüssel mit einem anderen Datentyp als `NONE` wurde definiert: Die Nachricht wird mit einem Schlüssel im angegebenen Datentyp versendet. Ein Schlüssel mit dem Datentyp `NONE` wurde definiert: Die Nachricht wird ohne Schlüssel versendet und eine Warnung wird im Server-Log ausgegeben. Es wurde kein Schlüssel definiert und der Datentyp des Schlüssels hat einen anderen Wert als `NONE`: Die Nachricht wird nicht versendet und eine Fehlermeldung wird ausgegeben. Es wurde kein Schlüssel definiert und der Datentyp des Schlüssels ist `NONE`: Die Nachricht wird ohne Schlüssel versendet.

Die Werte der Parameter trustStorePath, trustStorePassword, keyStorePath, keyStorePassword und privateKeyPassword können auch in der Datei apachekafka-config.xml definiert werden (siehe Apache Kafka).

Die Angaben über die Adapterkonfiguration überschreiben die Angaben in der apachekafka-config.xml. Dafür müssen aber alle Parameter gesetzt werden. Wenn nicht alle Parameter über die Adapterkonfiguration gesetzt werden, werden die Dateien aus der apachekafka-config.xml verwendet.

Wenn Adapterparameter verwendet werden, um die SSL-Konfiguration eines bestimmten Clients zu überschreiben, dann werden diese Werte beibehalten, bis sie erneut überschrieben oder der Server neugestartet wird.

Statuswerte

`1`	Die Adapter-Operation wurde erfolgreich ausgeführt.
`-1`	Bei der Ausführung des Adapters kam es zu einem Fehler.