Kafka Service

The Kafka Service can be used to connect to Kafka compliant servers (brokers) to receive specific topic-based messages for use in your Linx solution.

Properties

Return raw bytes

Selects whether to return the message as a list of bytes. Otherwise, messages will be deserialized via the specified schema registry.

Schema registery URL

Only available when Return raw bytes is not selected.

The URL of the schema registry to use to look up schemas.

Avro schemas

Only available when Return raw bytes is not selected.

The Avro schemas describing the key and value to deserialize.

Servers

A comma-separated list of the brokers to connect to in the format host:port.

Group ID

The consumer group ID.

Topic

The topic ID to consume on.

Service Event

MessageReceived

This is where you design your process flow for handling the messages that you receive. Drag and drop the relevant functions, types and processes onto the main canvas.


Also see: