基本配置

*数据源类型

BMQ

*接入方式

火山引擎 BMQ

*数据源名称

数据源的名称，可自行设置，仅支持中文，英文，数字，“_”，100个字符以内。

参数配置

*实例所属账号

实例所属账号支持选择当前云账号和其他云账号：

• 当前云账户：即当前登录控制台的云账号；
• 其他云账户：非当前登录的云账号，BMQ 数据源类型支持跨账号形式访问其他云账号下的 BMQ 实例，当选择其他云账户时，您需添加其他云账号 ID 和跨账号授权角色名称信息。

跨账号授权操作详见授权角色管理使用说明。

*BMQ 实例 ID

下拉选择已在火山引擎云原生消息引擎 BMQ 中创建的 BMQ 实例名称信息，可选当前云账户或其他云账户下的实例。
若您还未创建 BMQ 实例，您可前往 BMQ 实例控制台中创建，详见创建资源池。

*目标类型

数据去向目标类型选择 BMQ。

*数据源名称

已在数据源管理界面注册的 BMQ 数据源，下拉可选。
若还未建立相应数据源，可单击数据源管理按钮，前往创建 BMQ 数据源。

*Topic名称

选择 BMQ 处理消息源的不同分类主题名称，下拉可选数据源下对应需写入数据的 Topic 名称。

*数据格式

默认仅支持 json 格式，不可编辑。

示例数据

需以 json 字符串形式描述 schema。必须填写完整的数据，否则schema不准确。

分区设置

可以自定义 BMQ 分区规则，从 bmq message 字段中选择 0~N 个字段，用于保证指定字段相同的值写入到 BMQ 的同一 partition 中。

*目标类型

数据去向目标类型选择 BMQ。

*数据源名称

已在数据源管理界面注册的 BMQ 数据源，下拉可选。
若还未建立相应数据源，可单击数据源管理按钮，前往创建 BMQ 数据源。

*Topic名称

选择 BMQ 处理消息源的不同分类主题名称，下拉可选数据源下对应需读取数据的 Topic 名称。

*数据类型

支持 JSON、Pb，下拉可选，默认为 JSON 格式。
当选择Pb时，需要填写参数信息 Pb类定义 和 Pb Class。

示例数据

数据格式为 json 时，需以 json 字符串形式描述 schema。必须填写完整的数据，否则schema不准确。

*Pb 类定义

数据格式为 Pb 时，需要先定义 Pb 类，在框中中填写 Pb 的IDL定义，一次只支持一个 Pb 类的定义，示例如下：

syntax = "proto2";
package abase_test;
message AbaseTest {
    required int64 first_id = 1;
    required int64 latest_id = 2;
}

*Pb 类名

数据格式为 Pb 时，需要填写 PB Class 入口类名信息，
上方示例中的 PB Class 为 AbaseTest。