本文将为您介绍 EasyStream 中如何创建 RocketMQ 类型流表。

操作步骤

  1. 在流表管理页面，单击目标逻辑库，表单页面左上角显示对应库名表示切换成功。
  2. 单击 创建表 按键，进行表创建。
  3. 选择 数据源类型 为 RocketMQ。
  4. 完成剩余表单内容，创建 RocketMQ 流表。

流表配置

配置名称 是否必填 配置生效类型 参数值字段类型 参数默认值 参数说明
group 可选 源表、目标表 String - 消费者组 (consumerGroup)
tag 可选 源表、目标表 String - 读取的tag
start.message.offset 可选 源表 Integer -1 消息开始的偏移量
start.time.ms 可选 源表 Long -1 启动时间点。时间戳，单位为毫秒。
start.time 可选 源表 String - 启动时间点。字符串，形式为： 'yyyy-MM-dd HH:mm:ss'
end.time 可选 源表 String - 截止时间。字符串，形式为：'yyyy-MM-dd HH:mm:ss'
time.zone 可选 源表 String - 时区
partition.discovery.interval.ms 可选 源表 Long 30000 源表检查新分区的时间间隔，单位为ms。
use.new.api 可选 源表 Boolean true 是否启用新API，默认启用。
encoding 可选 目标表 String UTF-8 目标表编码
field.delimiter 可选 目标表 String \u0001 目标表字段分隔符
retry.times 可选 目标表 Integer 10 目标表写入失败重试次数
sleep.timeMs 可选 目标表 Long 5000L 目标表写入失败重试间隔时间，单位为毫秒
is.dynamic.tag 可选 目标表 Boolean false -
dynamic.tag.column 可选 目标表 String - -
dynamic.tag.column.write.included 可选 目标表 Boolean true -
write.keys.to.body 可选 目标表 Boolean false 是否将键写到body
key.columns 可选 目标表 String - 键列

特殊字段规则

数据源 特殊字段类型
RocketMQ 不支持varbinary字段；不支持metadata字段