本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

# 使用 `offset.storage.topic` 管理源连接器偏移
<a name="msk-connect-manage-connector-offsets"></a>

本节提供的信息可帮助您使用*偏移存储主题*管理源连接器偏移。偏移存储主题是 Kafka Connect 用来存储连接器和任务配置偏移的内部主题。

## 注意事项
<a name="msk-connect-manage-connector-offsets-considerations"></a>

在管理源连接器偏移时，请考虑以下几点。
+ 要指定偏移存储主题，请提供将连接器偏移作为工作程序配置中 `offset.storage.topic` 的值进行存储的 Kafka 主题名称。
+ 更改连接器配置时要谨慎行事。如果源连接器将配置中的值用于键偏移记录，则更改配置值可能会导致连接器出现意想不到的行为。我们建议您参考插件的文档以获取指导。
+ **自定义默认分区数** – 除了通过添加 `offset.storage.topic` 来自定义工作程序配置外，您还可以为偏移和状态存储主题自定义分区数量。内部主题的默认分区如下。
  + `config.storage.topic`：1，不可配置，必须是单分区主题
  + `offset.storage.topic`：25，可通过提供 `offset.storage.partitions` 进行配置
  + `status.storage.topic`：5，可通过提供 `status.storage.partitions` 进行配置
+ **手动删除主题** – Amazon MSK Connect 在每次部署连接器时都会创建新的 Kafka 连接内部主题（主题名称以 `__amazon_msk_connect` 开头）。附加到已删除连接器的旧主题不会自动删除，因为内部主题（例如 `offset.storage.topic`）可以在连接器之间重复使用。但是，您可以手动删除 MSK Connect 创建的未使用的内部主题。内部主题按照 `__amazon_msk_connect_<offsets|status|configs>_{{connector_name}}_{{connector_id}}` 格式命名。

  正则表达式 `__amazon_msk_connect_<offsets|status|configs>_{{connector_name}}_{{connector_id}}` 可用于删除内部主题。您不应删除正在运行的连接器当前正在使用的内部主题。
+ **对 MSK Connect 创建的内部主题使用相同名称** – 如果要重复使用偏移存储主题来消耗先前创建的连接器的偏移，则必须为新连接器指定与旧连接器相同的名称。可以使用工作程序配置来设置 `offset.storage.topic` 属性，以便将相同的名称分配到 `offset.storage.topic`，并在不同的连接器之间重复使用。[管理连接器偏移](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-workers.html#msk-connect-create-custom-worker-config)中描述了此配置。MSK Connect 不允许不同的连接器共享 `config.storage.topic` 和 `status.storage.topic`。每次在 MSKC 中创建新连接器时都会创建这些主题。它们会按照 `__amazon_msk_connect_<status|configs>_{{connector_name}}_{{connector_id}}` 格式自动命名，因此在您创建的不同连接器中会有所不同。