连接器消息处理属性

max.batch.size

类型： int

说明：
批处理的汇总水槽记录的最大数量。

考虑包含以下记录的批处理：

[ 1, 2, 3, 4, 5 ]

当设置为 0 时，连接器会对整个批处理执行单个批量写入。

当设置为 1 时，连接器会对批处理中的每条记录执行一次批量写入，共执行五次批量写入，如以下示例所示：

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

默认值：0
可接受值：整数

bulk.write.ordered

类型：布尔值

说明：
连接器是将一批记录写入作为有序或无序批量写入操作。当设置为 true（默认值）时，连接器会将一批记录写入作为有序批量写入操作。

要了解有关批量写入操作的更多信息，请参阅批量写入操作。

默认：true
可接受值：true 或 false

rate.limiting.every.n

类型： int

说明：
汇集连接器处理的记录批处理数量，以 trigger 限速超时。值为 0 表示没有限速。

默认：0
接受值：整数

rate.limiting.timeout

类型：int

说明：
在达到限速阈值后，汇总连接器应在多长时间（以毫秒为单位）后恢复处理。

默认值：0
可接受值：整数

tasks.max

类型：int

说明：
为此连接器创建的最大任务数。如果连接器无法处理您指定的并行处理级别，则它可能创建的任务少于指定的最大任务数。

重要：如果您指定的值大于 1，则连接器将启用任务的并行处理。如果您的主题有多个分区日志，这使连接器可以并行从主题中读取，则任务可能会无序处理消息。

默认值：1
接受值：整数