Kafka integrations enable you to automatically forward events that occur in Ably to Kafka topics.
Create a Kafka integration
On the Integrations page of your app:
- Click New Integration Rule.
- Choose Firehose.
- Choose Kafka.
- Configure the Kafka settings.
- Click Create.
Settings
The following settings are available when creating a Kafka integration:
| Setting | Description |
|---|---|
| Source | Specifies the event types being sent to Kafka. |
| Channel filter | Filters the source channels based on a regular expression. |
| Encoding | Specifies the encoding format of messages. Either JSON or MsgPack. |
| Enveloped | Checkbox to set whether messages should be enveloped or not. Enveloped is the default. |
| Routing key | Specifies the routing key used to route messages to Kafka topics. |
| Mechanism | The SASL/SCRAM mechanism used for Kafka connection. |
| Username | The username to connect to Kafka with. |
| Password | The password to connect to Kafka with. |
| Brokers | List of Kafka broker endpoints in the format <host>:<port>. |
Authentication mechanism
The available authentication mechanisms for Kafka are: