Kafka Trigger

Kafka is an open-source distributed event streaming platform that one can use for high-performance data pipelines, streaming analytics, data integration, and mission-critical applications.

Credentials

You can find authentication information for this node here.

Schema Registry

To decode messages with an authenticated Confluent Schema Registry (for example, Confluent Cloud), enable Use Schema Registry in the node and add a Schema Registry credential.

Message compression

The Kafka Trigger can consume uncompressed messages and messages compressed with GZIP. It can't decode messages compressed with LZ4, Snappy, or ZSTD (a common default for Confluent and JVM producers): consuming such a topic fails with an unsupported-compression-format error. To consume the topic, configure the producer to use gzip or no compression.

Examples and templates

For usage examples and templates to help you get started, refer to n8n's Kafka Trigger integrations page.