直接从 Kafka 加载数据时使用 TLS/SSL

您可以使用 COPY 语句和 KafkaSource 用户定义的加载函数从 Kafka 手动加载数据（请参阅手动使用来自 Kafka 的数据）。要让 KafkaSource 打开与 Kafka 的安全连接，必须为它提供 SSL 密钥和其他信息。

启动时，KafkaSource 函数会检查是否已定义多个用户会话变量。这些变量包含 SSL 密钥、用于对密钥进行签名的证书，以及该函数创建 SSL 连接所需的其他信息。有关这些变量的列表，请参阅 Kafka 用户定义的会话参数。如果 KafkaSource 发现已定义这些变量，则会使用它们创建与 Kafka 的 SSL 连接。

请参阅 Kafka TLS-SSL 示例第 4 部分：直接从 Kafka 加载数据，以获取有关在直接从 Kafka 复制数据时如何配置和使用 SSL 连接的逐步指南。

导出数据时，KafkaExport 函数也会使用这些变量来建立与 Kafka 的安全连接。