建立連接器

使用 建立連接器 AWS Management Console

1. 開啟位於 https://console.aws.amazon.com/msk/ 的 Amazon MSK 主控台。

2. 在左窗格的 MSK Connect 下，選擇連接器。

3. 選擇 Create connector (建立連接器)。

4. 您可選擇使用現有的自訂外掛程式來建立連接器，或先建立新的自訂外掛程式。如需有關自訂外掛程式以及如何建立的相關資訊，請參閱 建立自訂外掛程式。在此過程中，請假設您具有要使用的自訂外掛程式。在自訂外掛程式清單中，找到您要使用的外掛程式，然後選取其左側的方塊，然後選擇下一步。

5. 輸入名稱，以及描述 (非必要)。

6. 選擇您要連線到的叢集。

7. 指定連接器組態。您需要指定的組態參數會依據您要建立的連接器類型而定。然而，有部分參數是所有連接器都要指定的，例如 connector.class 和 tasks.max 參數。以下是 Confluent Amazon S3 目的地連接器的範例組態。

   connector.class=io.confluent.connect.s3.S3SinkConnector
   tasks.max=2
   topics=my-example-topic
   s3.region=us-east-1
   s3.bucket.name=amzn-s3-demo-bucket
   flush.size=1
   storage.class=io.confluent.connect.s3.storage.S3Storage
   format.class=io.confluent.connect.s3.format.json.JsonFormat
   partitioner.class=io.confluent.connect.storage.partitioner.DefaultPartitioner
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   schema.compatibility=NONE

8. 接下來，您需設定連接器容量。您可在兩種容量模式中選擇其一：佈建和自動擴展。如需關於這兩個選項的詳細資訊，請參閱了解連接器容量。

9. 在預設工作程序組態或自訂工作程序組態中選擇其一。如需有關建立自訂工作程序組態的詳細資訊，請參閱 了解 MSK Connect 工作者。

10. 接下來，您需指定服務執行角色。這必須是 MSK Connect 可以擔任的 IAM 角色，並授予連接器存取必要 AWS 資源所需的所有許可。這些許可會依連接器的邏輯而定。如需如何建立此角色的資訊，請參閱 了解服務執行角色。

11. 選擇下一步，檢閱安全性資訊，然後再次選擇下一步。

12. 指定所需的記錄選項，然後選擇下一步。如需日誌記錄的相關資訊，請參閱MSK Connect 的日誌。

13. 選擇 Create connector (建立連接器)。