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

DZone: What is Kafka?

kafka.apache.org