The Kafka system

This system can be used to read and write data from Apache Kafka as well as Azure Event Hubs for Apache Kafka.

Prototype

{
    "_id": "id-of-system",
    "name": "Name of system",
    "type": "system:kafka",
    "bootstrap_servers": "somehost:9092,otherhost:9092",
}

Properties

Property

Type

Description

Default

Req

bootstrap_servers

String

Comma separated list of bootstrap servers with hostname and port. For Azure Event Hubs this should be set to <fqdn>:9093.

Yes

sasl_username

String

Username to use when authentication against a SASL enabled Kafka cluster. If username is set, authentication will be performed. For Azure Event Hubs this property must be set to $ConnectionString and the connection string should be passed as the password.

No

sasl_password

String

Password to use when authentication against a SASL enabled Kafka cluster. For Azure Event Hubs this should be set to Endpoint=sb://[...].

No