连接器消息处理属性
概述
使用本页设置以配置 MongoDB Kafka 接收连接器的消息处理行为，包括以下内容
消息批量大小
速率限制
并行任务数量
有关按类别组织的接收连接器配置设置的列表，请参阅接收连接器配置属性指南.
设置
名称 | 描述 | ||
|---|---|---|---|
max.batch.size | 类型: int 描述 处理时一起批处理的最大 sink 记录数。 考虑包含以下记录的批次 当设置为 0，连接器为整个批次执行单个批量写入。当设置为 1，连接器为批次中的每条记录执行一个批量写入，总共五个批量写入，如下例所示默认值: 0可接受值: 一个整数 | ||
bulk.write.ordered | 类型: boolean 描述 连接器是否将记录批次作为有序或无序的批量写入操作。当设置为 true（默认值），连接器将记录批次作为有序的批量写入操作。有关批量写入操作的更多信息，请参阅批量写入操作。 默认值: true可接受值: true 或 false | ||
rate.limiting.every.n | 类型: int 描述 为了触发速率限制超时，sink 连接器处理的记录批次数。值为 0 表示没有速率限制。 默认值: 0可接受值: 一个整数 | ||
rate.limiting.timeout | 类型: int 描述 在 sink 连接器达到速率限制阈值后应恢复处理之前要等待多长时间（以毫秒为单位）。 默认值: 0可接受值: 一个整数 | ||
tasks.max | 类型: int 描述 为该连接器创建的最大任务数。如果连接器无法处理您指定的并行级别，则可能创建的任务数少于指定的最大任务数。 重要：如果指定值大于 1，连接器将启用任务的并行处理。如果您的主题有多个分区日志，这使连接器能够并行从主题中读取，则任务可能以错误的顺序处理消息。默认值: 1可接受值: 一个整数 |