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
Section titled “Properties ”Body type
Section titled “Body type”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
Section titled “Schema registery URL ”Only available when Return raw bytes is not selected.
The URL of the schema registry to use to look up schemas.
Authentication type
Section titled “Authentication type ”Specifies the authentication method to use in requests to the schema registry.
Username
Section titled “Username ”Only available when Authentication type is ‘Basic’.
Password
Section titled “Password ”Only available when Authentication type is ‘Basic’.
Sign with certificate
Section titled “Sign with certificate ”Select if requests to the schema registry must be signed using a certificate.
Avro schemas
Section titled “Avro schemas ”Only available when Return raw bytes is not selected.
The Avro schemas describing the key and value to deserialize.
Connection
Section titled “Connection”Servers
Section titled “Servers ”A comma-separated list of the brokers to connect to in the format host:port.
Group ID
Section titled “Group ID ”The consumer group ID.
Topic
Section titled “Topic ”The topic ID to consume on.
Security
Section titled “Security”Authentication protocol
Section titled “Authentication protocol ”The authentication protocol to use to authenticate with the broker.
Encryption protocol
Section titled “Encryption protocol ”The encryption protocol to use to communicate with the broker.
Only available when Authentication protocol is ‘SASL’.
SASL mechanism
Section titled “SASL mechanism”SASL mechanism to use for authentication.
Username
Section titled “Username”Not available when SASL mechanism is ‘GSSAPI’.
Password
Section titled “Password”Not available when SASL mechanism is ‘GSSAPI’.
Kerberos service name
Section titled “Kerberos service name”The principal name that Kafka runs as, excluding /hostname@REALM.
Only available when SASL mechanism is ‘GSSAPI’.
Kerberos principal
Section titled “Kerberos principal”The client’s principal name.
Only available when SASL mechanism is ‘GSSAPI’.
Only available when Encryption protocol is ‘SSL’.
CA location
Section titled “CA location”File or directory path to CA certificate for verifying the broker’s key.
Certificate location
Section titled “Certificate location”Path to client’s public key (PEM) used for authentication.
Key location
Section titled “Key location”Path to client’s private key (PEM) used for authentication.
Key password
Section titled “Key password”The private key passphrase.
Service Event
Section titled “Service Event ”MessageReceived
Section titled “MessageReceived ”This is where you design your process flow for handling the messages that you receive. Drag and drop the relevant functions and types onto the design canvas.