前提条件
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 类型数据。
参数说明如下:
参数 | 说明 |
数据源名称 | 新建的数据源的名称,由用户自定义且不可为空。命名以字母开头,可包含字母、数字、下划线。长度在20字符以内 |
描述 | 选填,对本数据源的描述 |
数据源权限 | 选择项目共享或仅个人与管理官可使用 |
部署方式 | 数据来源于自建实例或公网实例 |
区域和网络 | 选择账户下云数据库实例所在的地域、实例名称及 ID 信息 |
Kafka 服务列表 | 请输入服务列表,例如 ip1:9092,ip2:9092 |
Kafka 安全协议 | 请输入 Kafka 安全协议 |
Kafka sasl 机制 | 请输入 Kafka sasl 机制 |
Kafka sasl jaas 配置 | 请输入 Kafka sasl jaas 配置 |
数据连通性 | 测试是否能够连通所配置的数据库(若连通性测试不通过,会给出错误提示供排查原因,同时,数据源仍可保存,但该数据源使用时会发生异常) |