send Kafka message()
Important note: Our Kafka support is in beta version.
This function allows messages to be sent to Kafka brokers.
Parameters
Parameter |
Description |
a |
The Kafka alias. |
b |
The topic to which the message is sent. |
c |
The (optional) key of the message to be sent. |
d |
The data of the message to be sent. |
e |
The data type of the key. Note: Use the three dots to select a value. 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 Integration as a consumer is blocked until someone removes this erroneous message from the broker and it does not process any messages from this topic! |
f |
The data type of the data. Note: Use the three dots to select a value. 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 Integration as a consumer is blocked until someone removes this erroneous message from the broker and it does not process any messages from this topic! |
g |
The encoding if a byte array is used (data type). Note: Use the three dots to select a value. |
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 Integration always uses UTF-8 as encoding.