配置Kafka/DMS Kafka源端参数

Topics

支持单个或多个topic。

est1,est2

偏移量参数

从Kafka拉取数据时的初始偏移量：

• 最新：最大偏移量，即拉取最新的数据。
• 最早：最小偏移量，即拉取最早的数据。
• 已提交：拉取已提交的数据。
• 时间范围：拉取时间范围内的数据。

最新

是否持久运行

用户自定义是否永久运行。

是

消费组ID

用户指定消费组ID。

如果是从DMS Kafka导出数据，专享版请任意输入，标准版请输入有效的消费组ID。

sumer-group

数据格式

解析数据时使用的格式：

• 二进制格式：适用于文件迁移场景，不解析数据内容原样传输。
• CSV格式：以CSV格式解析源数据。
• JSON：以JSON格式解析源数据。
• CDC（DRS_JSON）：以DRS_JSON格式解析源数据。

二进制格式

字段分隔符

默认为空格，使用Tab键作为分隔符请输入“\t”。

,

最大消息数/poll

可选参数，每次向Kafka请求数据限制最大请求记录数。

100

最大时间间隔/poll

可选参数，向Kafka请求数据的最大时间间隔。

100