send Kafka message(a,b,c,d,e,f,g)


Important note: Our Kafka support is in beta version.

This function allows messages to be sent to Kafka brokers.

Parameter Description

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_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!

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_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!

g

The encoding if a byte array is used (data type). Note: Use the three dots to select.

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.