连接器消息处理属性

max.batch.size

类型：int




描述：同时处理的批处理记录的最大数量。考虑包含以下记录的批处理：

[ 1, 2, 3, 4, 5 ]

设立为0 时，Connector会对整个批处理执行单次批量写入。设立为

1时，Connector会对批处理中的每条记录执行一次批量写入，总共执行五次批量写入，如以下示例所示：

[1], [2], [3], [4], [5]

默认值：0
接受值：整数

bulk.write.ordered

类型：布尔值


描述：Connector是否会将批处理记录写入有序或无序的批量写入操作。当设立为默认值 时，Connector会将批处理记录写入为有序的批量写入操作。要学习；了解有关批量写入操作的更多信息，请参阅批量写入操作。默认值：true



true
接受值：true 或false

rate.limiting.every.n

类型：int


描述：接收器Connector器为触发速率限制超时而处理的记录批次数。值为 表示没有速率限制。默认值：0

0
接受的值：整数

rate.limiting.timeout

类型：int


描述：接收器Connector在达到速率限制阈值后应恢复处理之前的等待时间（以毫秒为单位）。默认值：

0
接受值：整数

tasks.max

类型：int


描述：为此Connector创建的最大任务数。如果Connector无法处理您指定的并行度，则它创建的任务数可能会少于指定的最大任务数。重要提示：如果指定大于

1的值，Connector将启用任务的并行处理。如果您的主题有多个分区日志（这使Connector能够并行从主题读取），则任务可能会无序进程消息。默认值：

1
接受的值：整数