Erstellen eines Connectors von

Erstellen eines Connectors mit dem AWS-Managementkonsole

1. Öffnen Sie die Amazon-MSK-Konsole unter https://console.aws.amazon.com/msk/.

2. Wählen Sie im linken Bereich unter MSK Connect die Option Konnektoren.

3. Wählen Sie Konnektor erstellen).

4. Sie können wählen, ob Sie ein vorhandenes benutzerdefiniertes Plugin verwenden möchten, um den Konnektor zu erstellen, oder ob Sie zuerst ein neues benutzerdefiniertes Plugin erstellen möchten. Informationen zu benutzerdefinierten Plugins und deren Erstellung finden Sie unter Erstellen Sie benutzerdefinierte Plugins. Gehen wir bei diesem Verfahren davon aus, dass Sie über ein benutzerdefiniertes Plugin verfügen, das Sie verwenden möchten. Suchen Sie in der Liste der benutzerdefinierten Plugins nach dem Plugin, das Sie verwenden möchten, wählen Sie das Kästchen links davon aus und dann Weiter.

5. Geben Sie einen Namen und optional eine Beschreibung ein.

6. Wählen Sie den Cluster, zu dem Sie eine Verbindung herstellen möchten.

7. Wählen Sie im Abschnitt Connector-Netzwerkeinstellungen eine der folgenden Optionen für den Netzwerktyp aus:

   • IPv4(Standard) — IPv4 Nur für Verbindungen zu Zielen über

   • Dual-Stack — Für Konnektivität zu Zielen über IPv4 sowohl als auch IPv6 (nur verfügbar, wenn Ihren Subnetzen IPv6 CIDR-Blöcke zugeordnet sind) IPv4

8. Geben Sie die Konnektor-Konfiguration an. Die Konfigurationsparameter, die Sie angeben müssen, hängen vom Typ des Konnektors ab, den Sie erstellen möchten. Einige Parameter sind jedoch allen Konnektoren gemeinsam, z. B. die Parameter connector.class und tasks.max. Im Folgenden finden Sie eine Beispielkonfiguration für den Confluent Amazon S3 Sink Connector.

   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-bucketflush.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

9. Als Nächstes konfigurieren Sie die Kapazität Ihres Konnektors. Sie können zwischen zwei Kapazitätsmodi wählen: bereitgestellt und automatisch skaliert. Weitere Informationen zu diesen beiden Optionen finden Sie unter Verstehen Sie die Kapazität der Steckverbinder.

10. Wählen Sie entweder die Standard-Worker-Konfiguration oder eine benutzerdefinierte Worker-Konfiguration. Weitere Informationen zum Erstellen von benutzerdefinierten Worker-Konfigurationen finden Sie unter Verstehen Sie MSK-Connect-Mitarbeiter.

11. Geben Sie als nächstes die Service-Ausführungsrolle an. Dies muss eine IAM-Rolle sein, die MSK Connect übernehmen kann und die dem Connector alle Berechtigungen gewährt, die er für den Zugriff auf die erforderlichen AWS Ressourcen benötigt. Diese Berechtigungen hängen von der Logik des Konnektors ab. Weitere Informationen zum Erstellen dieser Rolle finden Sie unter Verstehen Sie die Rolle der Serviceausführung.

12. Wählen Sie Weiter, überprüfen Sie die Sicherheitsinformationen und wählen Sie dann erneut Weiter.

13. Geben Sie die gewünschten Protokollierungs-Optionen an und wählen Sie dann Weiter. Weitere Informationen zur Protokollierung finden Sie unter Protokollierung für MSK Connect.

14. Überprüfen Sie auf der Seite Überprüfen und erstellen Ihre Connector-Konfiguration und wählen Sie Connector erstellen aus.