Response Route Kafka


images/download/thumbnails/44945603/arrow_up-version-1-modificationdate-1583211589593-api-v2.png Introduction: You can find a description of this phase in section Phase 6 (Introduction).


images/download/thumbnails/44945603/image2020-3-19_16-10-24-version-1-modificationdate-1584587421879-api-v2.png

images/download/attachments/44945603/1174-version-1-modificationdate-1656395599844-api-v2.png


Note: See also section File Names, File Patterns, Paths, System Constants and Variables.

(1) The Kafka alias. See section Kafka Connections.

(2) The topic to which the message is sent. Note: If the system variable KAFKA_PARTITION of type Integer is defined and has a value >= 0 , this value will be passed as the topic of the partition to be used.

(3) The data type of the message data to be sent. Important note: The data type must always be specified. Make sure that you always use matching types when sending and receiving. If, for example, a message is defined and sent as Byte/String and then read as Integer/Byte, this leads to an error and the message cannot be read. Lobster_data as a consumer is blocked until someone removes this erroneous message from the broker and it does not process any messages from this topic!

(4) The data type of the key of the message. Important note: The data type must always be specified. Make sure that you always use matching types when sending and receiving. If, for example, a message is defined and sent as Byte/String and then read as Integer/Byte, this leads to an error and the message cannot be read. Lobster_data as a consumer is blocked until someone removes this erroneous message from the broker and it does not process any messages from this topic!

(5) The (optional) key of the message.

(6) An optional identifier of a Kafka consumer (in a consumer group) that is passed to a Kafka broker with every request.

(7) Additional producer properties can be defined via the context menu.

Note: If the system variable KAFKA_TOMBSTONE is set to true, a tombstone record is sent (this can be used to prematurely delete records in certain topics).

Header Properties


You can transfer header properties with system variables of the form KAFKA_<keyname>. Note: Since only byte arrays can be specified as value for a header property, Lobster_data always uses UTF-8 as encoding.

Input Agent


See section Kafka (Input Agent) .