Kafka 触发器节点

Kafka 是一个开源的分布式事件流平台，可用于高性能数据管道、流分析、数据集成和关键任务应用程序。

凭据

您可以在这里找到此节点的身份验证信息。

Schema Registry

要使用经过身份验证的 Confluent Schema Registry（例如 Confluent Cloud）解码消息，请在节点中启用 Use Schema Registry 使用 Schema Registry，并添加 Schema Registry 凭据。

消息压缩

Kafka Trigger 可以使用未压缩的消息以及使用 GZIP 压缩的消息。它无法解码使用 LZ4、Snappy 或 ZSTD（Confluent 和 JVM producer 的常见默认值）压缩的消息；使用此类 topic 时会因不支持的压缩格式而失败。要使用该 topic，请将 producer 配置为使用 gzip 或不压缩。

示例和模板

有关帮助您入门的使用示例和模板，请参阅 n8n 的 Kafka Trigger 集成页面。