Kafka

logiccloud Control can connect to an Apache Kafka cluster to publish process variables to, and consume messages from, Kafka topics. To do this, a new connection of type Kafka must be created.

Create a new Kafka connection

Select Add Kafka connection and enter the broker information. After the connection has been created, select it in the outline tree to edit its configuration.

Connection settings:

• Name: Name of the connection
• Description: Description, optional
• Bootstrap servers: comma-separated list of Kafka broker addresses (host:port)

Sending and receiving data through Kafka

As with MQTT, a Kafka connection can work as a producer (publishes process variable values to a topic; maps Output variables) or as a consumer (reads messages from a topic into Input variables).

To create a producer or consumer, right-click the connection in the tree and choose the corresponding action.

Mapping process variables

After adding a producer or consumer, you can map process variables to the Kafka message payload.

• Variable: the program variable that will be mapped
• Data type: data type of the variable