有奖捉虫:办公协同&微信生态&物联网文档专题 HOT

操作场景

腾讯云数据连接器中的 Kafka 连接器支持 PLAINTEXT、SASL_PLAINTEXT、SASL_SCRAM 三种认证方式接入 Kafka 集群,可使用任一被支持的认证方式接入到 Kafka 集群。

前期准备

前提条件

已配置好安全组规则和公网 IP,并开通 Kafka 服务。
华为云仅以下地域支持开通公网访问:
华北-北京一华北-北京四
华北-乌兰察布一
华东-上海一
华东-上海二
华南-广州

设置安全组

1. 登录华为云控制台,进入 安全组 设置。
2. 新建安全组或者修改已有安全组。


新建安全组
修改已有安全组
1. 单击控制台右上角的创建安全组,进入安全组创建页面,模板选择自定义。
image-20220325104730507


2. 单击配置规则。
image-20220325104804412


3. 添加如下入站规则。
方向
协议
端口
源地址
说明
入方向
TCP
9094
0.0.0.0/0
通过公网访问 Kafka(关闭 SSL 加密)。
入方向
TCP
9092
0.0.0.0/0
通过 VPC 内网访问 Kafka(关闭 SSL 加密)。
入方向
TCP
9095
0.0.0.0/0
通过公网访问 Kafka(开启 SSL 加密)。
入方向
TCP
9093
0.0.0.0/0
通过 VPC 内网访问 Kafka(开启 SSL 加密)。
入方向
TCP
9999
0.0.0.0/0
访问 Kafka Manager。

1. 在安全组实例列表中,单击要修改的安全组实例右侧的配置规则,对已有规则进行修改。
image-20220325105256075


2. 修改入方向规则,添加如下入站规则。
方向
协议
端口
源地址
说明
入方向
TCP
9094
0.0.0.0/0
通过公网访问 Kafka(关闭 SSL 加密)。
入方向
TCP
9092
0.0.0.0/0
通过 VPC 内网访问 Kafka(关闭 SSL 加密)。
入方向
TCP
9095
0.0.0.0/0
通过公网访问 Kafka(开启 SSL 加密)。
入方向
TCP
9093
0.0.0.0/0
通过 VPC 内网访问 Kafka(开启 SSL 加密)。
入方向
TCP
9999
0.0.0.0/0
访问 Kafka Manager。


购买公网 IP

1. 进入 弹性公网 IP 控制台,单击右上角的购买弹性公网 IP


2. 按实际情况选择计费模式,设置区域,线路和带宽等参数。
3. 单击立即购买



接入配置

步骤1:设置 Kafka 接入方式

1. 登录 消息队列 Kafka 控制台,在实例列表中选择要设置的实例。


2. 单击实例名称进入详情页,单击安全组,完成安全组绑定。 若前置条件中直接修改的是 Sys-default 安全组,可省略该步骤。


3. 打开公网访问,从可用弹性 IP 中选择公网 IP 进行绑定,并确定。


4. 等待公网绑定结束后,即可获取到公网访问地址,SASL_SSL 模式的设置可参见 华为云帮助文档
注意
华为云 Kafka 实例不支持动态修改 SASL_SSL 模式,请重新创建实例,并在创建实例时开启 SASL_SSL 认证。




步骤2: 配置腾讯云数据连接器 Kafka 连接器连接属性

1. 腾讯云数据连接器控制台上单击新建应用,选择空白应用进行创建。


2. 单击左侧的集成流展开选择 NewFlow 在画布中单击 +选择 Apache Kafka 连接器相关操作。


3. 单击右侧的新建连接器配置并按照指引填入相关参数。


4. 单击下一步以使用PLAINTEXT接入点为例,在连接器配置参数中,依次填写如下配置:
集群地址:填入 Kafka 公网连接地址,可参见 获取公网访问地址
集群 Kafka 版本:根据购买的 Kafka 实例版本选择对应的版本。
SASL 安全认证模式:选择 PLAINTEXT。
使能 TLS 安全传输协议:选择 false。


5. 其他 Kafka 参数请按实际情况填写,也可参见 Apache Kafka 连接器使用指南