Erstellen eines Konnektors

Erstellen eines Connectors mit dem AWS Management Console

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

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

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

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

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

13. Wählen Sie Konnektor erstellen.