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
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
Only available when Return raw bytes is not selected.
The URL of the schema registry to use to look up schemas.
Authentication type
Specifies the authentication method to use in requests to the schema registry.
Username
Only available when Authentication type is 'Basic'.
Password
Only available when Authentication type is 'Basic'.
Sign with certificate
Select if requests to the schema registry must be signed using a certificate.
Avro schemas
Only available when Return raw bytes is not selected.
The Avro schemas describing the key and value to deserialize.
Connection
Servers
A comma-separated list of the brokers to connect to in the format host:port.
Misc
Group ID
The consumer group ID.
Topic
The topic ID to consume on.
Security
Authentication protocol
The authentication protocol to use to authenticate with the broker.
Encryption protocol
The encryption protocol to use to communicate with the broker.
SASL
Only available when Authentication protocol is 'SASL'.
SASL mechanism
SASL mechanism to use for authentication.
Warning: Usage of 'GSSAPI' as
SASL mechanism
is currently experimental and may not work in all circumstances.
Username
Not available when SASL mechanism is 'GSSAPI'.
Password
Not available when SASL mechanism is 'GSSAPI'.
Kerberos service name
The principal name that Kafka runs as, excluding /hostname@REALM. Only available when SASL mechanism is 'GSSAPI'.
Kerberos principal
The client's principal name. Only available when SASL mechanism is 'GSSAPI'.
SSL
Only available when Encryption protocol is 'SSL'.
CA location
File or directory path to CA certificate for verifying the broker's key.
Certificate location
Path to client's public key (PEM) used for authentication.
Key location
Path to client's private key (PEM) used for authentication.
Key password
The private key passphrase.
Service Event
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.
Links
Last updated