Operation: Subscribe

Die Operation Subscribe abonniert ein Topic, um Nachrichten zu erhalten. Dabei wird ein vorhandener Client aus der Datei apachekafka-config.xml verwendet.

Erforderliche Parameter: clusterId, clientId, topic, process

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

Für die Operaton Subscribe kann nur ein Client verwendet werden, der noch nicht für ein anderes Topic verwendet wird. Ein Client kann nicht mehrere Topics abonnieren.

Das bedeutet, die Operation Subscribe 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

Dieser Adapter erwartet keinen Input.

Output

Für die Operation Subscribe wird kein direkter Output ausgegeben. Wenn in einem abonnierten Topic 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>