Important note: Our Kafka support is in beta version.

Introduction: Phase 6.

(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.