

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

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

本節提供的資訊有助您使用*偏移儲存主題*來管理來源連接器偏移。偏移儲存主題是一項內部主題，Kafka Connect 會用來存放連接器和任務組態偏移。

## 考量事項
<a name="msk-connect-manage-connector-offsets-considerations"></a>

在管理來源連接器偏移時，請考量以下事項。
+ 若要指定偏移儲存主題，請提供 Kafka 主題的名稱，其連接器偏移會被儲存為工作程序組態中的 `offset.storage.topic` 值。
+ 在變更連接器組態時請小心。若來源連接器會將組態中的值用於關鍵偏移記錄，則變更組態值可能會導致意外的連接器行為。我們建議您參考外掛程式的文件以取得指引。
+ **自訂預設分區數量** - 除了藉由新增 `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}}` 格式自動命名，因此它們的名稱在您建立的不同連接器之間也會有所不同。