SignalReceiver¶
Kurzbeschreibung¶
SignalReceiver ist ein SignalIn Brick. Er empfängt Daten, die von einem SingalOut in das titan internen Kafka-System entsendet werden, und gibt sie in den Flow weiter.
Output¶
SignalReceiver besitzt einen Output-Port.
output = variant : doc "arbitrary payload received from a kafka
topic (any ujo data)";
Als Input empfängt SignalReceiver die Daten, die es von einem SingalOut Brick bekommt.
Parametrisierung¶
Signal Receiver besitzt folgende Parameter:
Topics
Topics¶
Topics
: Liste der Kafka Topics aus denen Nachrichten empfangen werden sollen.
Standardwert:
string
Pflichtfeld
Funktion¶
SignalReceiver empfängt Messages aus dem titan internen Kafka-System.
Auf eingehende Nachrichten wird auf den in Topics
angegbene streams gewartet.
Die anzugebenden Topics
folgen dabei dem Schema: <flowname.signalbrickname>
,
um Nachrichten eines Signal Emitters im selben oder in einem anderen Flow zu
empfangen.