N8N中文教程
集成节点/Built in_nodes/Credentials

Kafka 凭据#

你可以使用这些凭据来认证以下节点:

  • Kafka
  • Kafka Trigger

支持的认证方式#

  • Client ID(客户端 ID)

相关资源#

更多关于服务使用的详细信息,请参考 Kafka 官方文档。 如果你是 Kafka 的新手,可以参考 Apache Kafka 快速入门指南 进行初始环境设置。 如需在 Kafka 中使用 SSL,请参考 使用 SSL 的加密与认证。

使用客户端 ID#

要配置此凭据,你需要一个正在运行的 Kafka 环境,并准备以下信息:

  • 一个 Client ID(客户端 ID)
  • 一组相关的 Brokers(代理服务器列表)
  • 如果你的 Kafka 环境启用了认证,还需要提供用户名和密码

配置步骤如下:

  1. 在凭据的 Client ID 字段中输入客户端或消费者组的 CLIENT-ID
  2. 在字段中以 <broker-service-name>:<port> 格式输入用逗号分隔的相关 Brokers 列表。使用你在 services 列表中为 broker 定义的名称。例如,kafka-1:9092,kafka-2:9092 将添加端口为 9092kafka-1kafka-2 两个 broker。
  3. 如果你的 Kafka 环境未使用 SSL,请关闭 SSL 开关。
  4. 如果你在 Kafka 环境中启用了 SASL 认证,请打开 Authentication(认证)开关,然后填写以下信息:
  5. Username(用户名)
  6. Password(密码)
  7. 选择 broker 配置的 SASL Mechanism(SASL 机制)。更多信息请参考 SASL 配置文档。可选项包括:
    • Plain
    • scram-sha-256
    • scram-sha-512