跳转到内容

Apache Kafka 是一个分布式事件流平台。将此连接与 导入 Kafka 步骤配合使用,可将主题的消息读入表;与 导出 Kafka 步骤配合使用,可将表的每一行作为一条消息发送。创建时,请选择 Apache Kafka 作为连接类型。

Apache Kafka 文档。

字段 是否必填 说明
Brokers 是 要连接的 broker,以逗号分隔,例如 broker1:9092,broker2:9092。
安全协议 否 PLAINTEXT(默认)、SSL、SASL_PLAINTEXT 或 SASL_SSL。
会话超时(毫秒) 否 broker 在多长时间内未收到 PlaidCloud 的消息,就将其从消费者组中移除。至少为 1000。

当安全协议为 SASL_PLAINTEXT 或 SASL_SSL 时使用。

字段 说明
SASL 机制 PLAIN(默认)、SCRAM-SHA-256、SCRAM-SHA-512 或 OAUTHBEARER。不支持 Kerberos(GSSAPI)。
用户 连接时使用的用户,适用于 PLAIN 和 SCRAM。
密码 该用户的密码(只写),适用于 PLAIN 和 SCRAM。

当 SASL 机制为 OAUTHBEARER 时使用。PlaidCloud 使用 OAuth 客户端凭据授权从您的身份提供商获取令牌,并在令牌过期时获取新令牌。

字段 说明
令牌端点 URL 身份提供商的令牌端点。必须是公共互联网上的 https 地址。
客户端 ID 请求令牌时使用的客户端。必填。
客户端密钥 客户端的密钥(只写)。必填。
范围 当您的提供商需要时,要请求的范围。
SASL 扩展 可选的 key=value 键值对,以逗号分隔,随令牌一起发送,例如 Confluent Cloud 要求的 logicalCluster 和 identityPoolId。
字段 说明
CA 证书(PEM) 签发 broker 证书的证书颁发机构(如果它不是公共机构)。编辑时留空可保留已保存的证书。