前提条件
1. 版本
Kafka 版本0.11及以上。
2. 自建 Kafka
自建 Kafka 和集成资源组的网络需要打通。
使用限制
Kafka 版本0.11及以上。
注意事项
Kafka 客户端与服务端建立连接的过程如下所示:
1. 客户端使用您指定的 bootstrap.servers 地址连接 Kafka 服务端,Kafka 服务端根据配置向客户端返回集群中各台 broker 的元信息,包括各台 broker 的连接地址。
2. 客户端使用第一步 broker 返回的连接地址连接各台 broker 进行读取或写入:
我们需要注意当 bootstrap.servers 地址可以连通时,还是报网络问题连通性问题,可以排查下 Kafka 服务端返回的 broker 连接地址是否连通性存在问题。可以检查 Kafka broker 配置文件 server.properties 中 listeners 和 advertised.listeners 的地址是否可以和集成资源组网络连通。
数据源配置
目前支持通过连接串方式引入 Kafka 类型数据。
![](https://qcloudimg.tencent-cloud.cn/image/document/438e23a35555897dc13b742dec650afd.png)
![](https://qcloudimg.tencent-cloud.cn/image/document/438e23a35555897dc13b742dec650afd.png)
参数说明如下:
参数 | 说明 |
数据源名称 | 新建的数据源的名称,由用户自定义且不可为空。命名以字母开头,可包含字母、数字、下划线。长度在20字符以内 |
描述 | 选填,对本数据源的描述 |
数据源权限 | 选择项目共享或仅个人与管理官可使用 |
部署方式 | 数据来源于自建实例或公网实例 |
区域和网络 | 选择账户下云数据库实例所在的地域、实例名称及 ID 信息 |
Kafka 服务列表 | 请输入服务列表,例如 ip1:9092,ip2:9092 |
认证方式 | 支持 PLAINTEXT、SASL_PLAINTEXT、SASL_SSL、JAAS 四种认证方式: 如果选择 SASL_PAINTEXT 认证方式,需要填写用户名、密码; 如果选择 SASL_SSL 认证方式,需要填写 TrustStore 认证文件、TrustStore 密码、用户名、密码; 如果选择 JAAS 认证方式,需要填写 Kafka sasl jaas 配置。 |
数据连通性 | 测试是否能够连通所配置的数据库(若连通性测试不通过,会给出错误提示供排查原因,同时,数据源仍可保存,但该数据源使用时会发生异常) |