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.