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

# 將接收器連接器遷移至 Amazon MSK Connect
<a name="msk-connect-migrate-sink-connectors"></a>

接收器連接器是將資料從 Kafka 匯出到外部系統的 Apache Kafka Connect 應用程式。本節說明將執行內部部署或自我管理 Kafka Connect 叢集的 Apache Kafka Connect 接收器連接器應用程式遷移 AWS 至 Amazon MSK Connect 的程序。

Kafka Connect 接收器連接器使用 Kafka 群組成員資格 API，並將偏移存放在與典型消費者應用程式相同的`__consumer_offset`主題中。此行為可簡化從自我管理叢集到 Amazon MSK Connect 的接收器連接器遷移。

若要將接收器連接器遷移至 Amazon MSK Connect，請執行下列動作：

1. 從您的內部部署或自我管理 Kafka Connect 叢集中提取連接器程式庫，以建立 Amazon MSK Connect [自訂外掛程式](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-plugins.html)。

1. 建立 Amazon MSK Connect [工作者屬性](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-config-provider.html#msk-connect-config-providers-create-custom-config)，並將屬性 `value.converter` `key.converter`和 設定為與現有 Kafka Connect 叢集中執行之 Kafka 連接器相同的值。

1. 在現有的 Kafka Connect 叢集上提出`PUT /connectors/{{connector-name}}/pause`請求，以暫停現有叢集上的連接器應用程式。

1. 確定連接器應用程式的所有任務都已完全停止。您可以停止任務，方法是在現有的 Kafka Connect 叢集上提出`GET /connectors/{{connector-name}}/status`請求，或取用屬性 所設定主題名稱的訊息`status.storage.topic`。

1. 從現有叢集取得連接器組態。您可以透過在現有叢集上提出`GET /connectors/{{connector-name}}/config`請求，或從屬性 設定的主題名稱取用訊息，來取得連接器組態`config.storage.topic`。

1. 使用與現有叢集相同的名稱建立新的 [Amazon MSK Connector](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-connectors.html)。使用您在步驟 1 中建立的連接器自訂外掛程式、您在步驟 2 中建立的工作者屬性，以及您在步驟 5 中擷取的連接器組態，來建立此連接器。

1. 當 Amazon MSK Connector 狀態為 時`active`，請檢視日誌以確認連接器已開始從來源系統匯入資料。

1. 透過提出`DELETE /connectors/{{connector-name}}`請求，刪除現有叢集中的連接器。