Apache Kafka Connector: Konfiguration

Um den Adapter zu verwenden, ist eine Konfigurationsdatei auf Hauptebene des Projektes mit der Endung .kafka erforderlich.

Die Werte für clientId, pollIntervallMillis und maxRequestsToBroker können auch über Adapterparameter gesetzt werden.

Wenn nicht alle Parameter über die Adapterkonfiguration gesetzt werden, werden die Dateien aus kafka.kafka verwendet.

Information zur Funktion des Adapters:

Der Adapter veröffentlicht Nachrichten anhand der ClientID und abonniert Topics entsprechend den Parametern, die in der Konfigurationsdatei gesetzt sind.

Es ist nur möglich, alle Topics zu abonnieren. Nach dem Abonnement werden alle Nachrichten von allen Topics empfangen. Das Abonnement läuft im Hintergrund mit der definierten Häufigkeit der Abrufe. Wenn neue Nachrichten veröffentlicht werden, werden diese automatisch empfangen.

Beispiel für eine Konfigurationsdatei:

CODE

<?xml version="1.0" encoding="UTF-8"?>
<KafkaConfiguration>
	<threadPoolSize>10</threadPoolSize> 
	<broker server = "localhost:29092"> 
		<client id="1">
			<topic filter="topic1"></topic>
			<pollIntervallMillis>50</pollIntervallMillis>
			<process url="Processes/data.wrf"></process>
			<maxRequestsToBroker>10</maxRequestsToBroker>
		</client>
	</broker>
</KafkaConfiguration>

Folgende Attribute und Elemente sind in der Konfigurationsdatei enthalten:

Element / Attribut	Beschreibung
`KafkaConfiguration`	Wurzelelement der Konfigurationsdatei
`threadPoolSize`	Anzahl verwendbarer Threads
`broker server`	Host und Port des Brokers
`client id`	ID des Clients, mit dem die Nachricht veröffentlicht wird
`topic filter`	Topic, das abonniert werden kann, um die veröffentlichte Nachricht zu erhalten. Es hat folgendes Attribut: `filter`: Name des Topic-Filters
`pollIntervallMillis`	Häufigkeit der Abrufe von Nachrichten vom Broker während des Abonnements in Millisekunden Beispiel: 50 bedeutet, dass der Teilnehmer alle 50 Millisekunden Nachrichten vom Broker abruft. Er ruft nur Nachrichten ab, die noch nicht abgerufen wurden. Mögliche Werte: `Ganzzahl über 0`
`process url`	Gibt an, in welchem Prozess die empfangenen Daten verwendet werden sollen. Die empfangenen Daten werden als XML in den Prozess geschrieben. Mögliche Werte: Pfad zum Prozess Beispiel: `"Processes/data.wrf"`
`maxRequestsToBroker`	Mit dem Parameter `maxRequestToBroker` kann die maximale Anzahl der erlaubten Nachrichten festgelegt werden, die ohne eine Antwort des Brokers veröffentlicht werden können. Dies ist notwendig, da die Clients der `.kafka`-Konfiguration gleichzeitig Publisher und Subscriber sein können.