Operation: Assign

Die Operation Assign weist einem Consumer manuell eine Liste von Partitionen zu. Dabei wird ein vorhandener Client aus der Datei apachekafka-config.xml verwendet.
Über die Operation Assign ist, im Vergleich zu der Operation Subscribe, eine feinere Kontrolle über die Partitionen möglich, die vom Consumer verarbeitet werden sollen.

Erforderliche Parameter: clusterId, clientId, topic, process

Die Operationen Assign und Subscribe schließen sich gegenseitig aus.

Für die Operation Assign kann nur ein Client verwendet werden, der noch nicht für ein anderes Topic verwendet wird. Ein Client kann nicht mehreren Topics zugewiesen werden.

Das bedeutet, die Operation Assign kann nur für einen spezifischen Client durchgeführt werden. Dieser Client ist dann belegt und kann nicht für andere Operation verwendet werden.

Input

Der Adapter erwartet keinen Input.

Output

Für die Operation Assign generiert der Adapter keinen direkten Output. Wenn in einer zugewiesenen Partition eine neue Nachricht empfangen wird, dann wird ein Prozess mit der empfangenen Nachricht als Input gestartet. Diese Nachricht wird in folgender Struktur übergeben:

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<Message>
    <ClusterId>X4Kafka</ClusterId>
    <Topic>noKeyTopic</Topic>
    <Offset>0</Offset>
	<Headers>
		<Header key="value 1">header1</Header>
        <Header key="value 2">header2</Header>
        <Header key="value 3">header3</Header>
	</Headers>
    <Content encoding="base64"key="055b93a8-4eda-41d8-8b73-b852a1d4da1e">055b93a8-4eda-41d8-8b73-b852a1d4da1e</Content>
</Message>