Overview
您可以通过重置偏移量来手动更改消费者群组在Apache Kafka主题分区中处理消息的位置。重置通常会将偏移量移动到较早的位置,例如主题的开头,以便Connector从该点开始重新处理消息。您还可以将偏移量移到稍后的位置以跳过消息。
重置源连接器偏移量
MongoDB Kafka源Connector提供了一种使用offset.partition.name 配置属性重置偏移量的方法。要学习;了解更多信息,请参阅 重置存储的偏移量。
重置接收器连接器偏移
MongoDB不支持重置MongoDB Kafka SinkConnector的偏移量。但是,您可以使用Apache Kafka消费者群组工具重置与接收器Connector关联的消费者群组的偏移量。
要学习;了解详情,请参阅 Confluence 文档中的 Kafka消费者群组工具 页面。
Considerations
在重置MongoDB Kafka源Connector或MongoDB Kafka接收Connector偏移之前,请考虑以下事项:
重置偏移量可能会导致数据不一致或数据丢失,因为消息可能会被跳过或重新处理。请谨慎使用此过程。
此过程中的命令仅适用于Apache Kafka ,不适用于您的MongoDB 部署。所需步骤可能因提供商和配置而异。查看Kafka提供商的文档,并与提供商或管理员确认此过程适合您的环境。