Apache Kafka Subscriber

Der Adapter ermöglicht es, Nachrichten zu einem bestimmten Topic zu abonnieren, das Abonnement zu beenden oder die letzte Nachricht zu lesen.

Eigenschaften (Properties)

Operation

Definiert die vom Adapter ausgeführte Operation.

Mögliche Werte:

Assign: Weist einem Consumer manuell eine Liste von Partitionen zu.
Subscribe: Abonniert ein Topic, um Nachrichten zu erhalten.
Unsubscribe: Trennt Client und Topic und beendet die Zuweisung bzw. das Abonnement eines bestimmten Topics.
Last offset: Gibt den Offset eines bestimmten Clients bei dessen abonnierten Topic zurück.

Parameter

`Adapter`	Adapter-Hauptklasse (nicht verändern!) Mögliche Werte: de.softproject.integration.adapter.apachekafka.ApacheKafkaSubscriberAdapter: 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, mit dem das Topic abonniert 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 das Topic abonniert 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, das abonniert wird Mögliche Werte: Zeichenkette aus alphanumerischen ASCII-Zeichen, `.` (Punkt), `_` (Unterstrich) und `-` (Bindestrich) oder kommagetrennte Liste aus mehreren Zeichenketten, um mehrere Topics zu abonnieren
`process`	Prozess, der ausgeführt wird, nachdem eine Nachricht empfangen wurde. Mögliche Werte: Zeichenkette aus alphanumerischen ASCII-Zeichen, `.` (Punkt), `_` (Unterstrich) und `-` (Bindestrich)
`consumerPosition`	Offset, mit dem Nachrichten empfangen werden, wenn ein Topic abonniert wird. Mögliche Werte: Ganzzahl größer als `0` Dieser Parameter hat nur einen Effekt, wenn ein einzelnes Topic abonniert wird. Wenn mehrere Topics abonniert werden, hat dieser Parameter keine Auswirkungen.
`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): Kein Datentyp Hat der Subscriber ein Topic abonniert und der `keyDataType` hat den Wert `NONE`, werden ausschließlich Nachrichten ohne Schlüssel empfangen. Ist der Wert ein anderer als `NONE`, werden Nachrichten mit allen anderen Datentypen empfangen. Hat die Nachricht einen Schlüssel, wird der Schlüssel als Attribut im Element `Content` ausgegeben. `BYTES`: Base64-kodierter Wert `BYTEARRAY`: Base64-kodierter Wert `DOUBLE`: Gleitkommazahl `FLOAT`: Gleitkommazahl `INTEGER`: Ganzzahl `LONG`: Ganzzahl `SHORT`: Ganzzahl `STRING` (Standard): Zeichenkette `UUID`: Java UUID

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.