Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
# EventBridge Kafka-Sink-Anschluss für MSK Connect einrichten
In diesem Thema erfahren Sie, wie Sie den [EventBridge Kafka-Sink-Connector](https://github.com/awslabs/eventbridge-kafka-connector) für MSK Connect einrichten. [Mit diesem Connector können Sie Ereignisse von Ihrem MSK-Cluster an Event-Busse senden. EventBridge ](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-event-bus.html) In diesem Thema wird der Prozess zum Erstellen der erforderlichen Ressourcen und zum Konfigurieren des Connectors beschrieben, um einen nahtlosen Datenfluss zwischen Kafka und zu ermöglichen. EventBridge
**Topics**
+ [Voraussetzungen](#mkc-eb-kafka-prerequisites)
+ [Richten Sie die für MSK Connect erforderlichen Ressourcen ein](#mkc-eb-kafka-set-up-resources)
+ [Erstellen Sie den Connector](#mkc-eb-kafka-create-connector)
+ [Senden Sie Nachrichten an Kafka](#mkc-eb-kafka-send-json-encoded-messages)
## Voraussetzungen
Stellen Sie vor der Bereitstellung des Connectors sicher, dass Sie über die folgenden Ressourcen verfügen:
+ **Amazon MSK-Cluster**: Ein aktiver MSK-Cluster zur Erzeugung und Verarbeitung von Kafka-Nachrichten.
+ ** EventBridge Amazon-Eventbus**: Ein EventBridge Eventbus, um Veranstaltungen zu den Kafka-Themen zu empfangen.
+ **IAM-Rollen**: Erstellen Sie IAM-Rollen mit den erforderlichen Berechtigungen für MSK Connect und den Connector. EventBridge
+ [Zugriff auf das öffentliche Internet über](msk-connect-internet-access.md) MSK Connect oder einen [VPC-Schnittstellenendpunkt, der in der VPC](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-related-service-vpc.html) und im Subnetz Ihres MSK-Clusters EventBridge erstellt wurde. Auf diese Weise vermeiden Sie das Durchqueren des öffentlichen Internets und benötigen keine NAT-Gateways.
+ Ein [Client-Computer](create-serverless-cluster-client.md), z. B. eine Amazon EC2 EC2-Instance oder [AWS CloudShell](https://aws.amazon.com/cloudshell/), um Themen zu erstellen und Datensätze an Kafka zu senden.
## Richten Sie die für MSK Connect erforderlichen Ressourcen ein
Sie erstellen eine IAM-Rolle für den Connector und anschließend den Connector. Sie erstellen auch eine EventBridge Regel zum Filtern von Kafka-Ereignissen, die an den EventBridge Event-Bus gesendet werden.
**Topics**
+ [IAM-Rolle für den Connector](#mkc-eb-kafka-iam-role-connector)
+ [Eine EventBridge Regel für eingehende Ereignisse](#mkc-eb-kafka-create-rule)
### IAM-Rolle für den Connector
Die IAM-Rolle, die Sie dem Connector zuordnen, muss über die [PutEvents](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-permissions-reference.html)Berechtigung verfügen, das Senden von Ereignissen an zu ermöglichen. EventBridge Das folgende Beispiel für eine IAM-Richtlinie erteilt Ihnen die Berechtigung, Ereignisse an einen Ereignisbus mit dem Namen zu senden. `example-event-bus` Stellen Sie sicher, dass Sie den Ressourcen-ARN im folgenden Beispiel durch den ARN Ihres Event-Busses ersetzen.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"events:PutEvents"
],
"Resource": "arn:aws:events:us-east-1:123456789012:event-bus/example-event-bus"
}
]
}
```
------
Darüber hinaus müssen Sie sicherstellen, dass Ihre IAM-Rolle für den Connector die folgende Vertrauensrichtlinie enthält.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "kafkaconnect.amazonaws.com"
},
"Action": "sts:AssumeRole"
}
]
}
```
------
### Eine EventBridge Regel für eingehende Ereignisse
Sie erstellen [Regeln](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-rules.html), die eingehende Ereignisse mit Kriterien für Ereignisdaten abgleichen, was als [https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-event-patterns.html](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-event-patterns.html) bezeichnet wird. Mit einem Ereignismuster können Sie die Kriterien für das Filtern eingehender Ereignisse definieren und festlegen, welche Ereignisse eine bestimmte Regel auslösen und anschließend an ein bestimmtes [Ziel](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-targets.html) weitergeleitet werden sollen. Das folgende Beispiel für ein Ereignismuster entspricht Kafka-Ereignissen, die an den EventBridge Event-Bus gesendet wurden.
```
{
"detail": {
"topic": ["msk-eventbridge-tutorial"]
}
}
```
Im Folgenden finden Sie ein Beispiel für ein Ereignis, das von Kafka EventBridge mithilfe des Kafka-Sink-Connectors an gesendet wurde.
```
{
"version": "0",
"id": "dbc1c73a-c51d-0c0e-ca61-ab9278974c57",
"account": "123456789012",
"time": "2025-03-26T10:15:00Z",
"region": "us-east-1",
"detail-type": "msk-eventbridge-tutorial",
"source": "kafka-connect.msk-eventbridge-tutorial",
"resources": [],
"detail": {
"topic": "msk-eventbridge-tutorial",
"partition": 0,
"offset": 0,
"timestamp": 1742984100000,
"timestampType": "CreateTime",
"headers": [],
"key": "order-1",
"value": {
"orderItems": [
"item-1",
"item-2"
],
"orderCreatedTime": "Wed Mar 26 10:15:00 UTC 2025"
}
}
}
```
[Erstellen Sie in der EventBridge Konsole mithilfe dieses Beispielmusters eine Regel](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-create-rule.html) für den Event-Bus und geben Sie ein Ziel an, z. B. eine CloudWatch Logs-Gruppe. Die EventBridge Konsole konfiguriert automatisch die erforderliche Zugriffsrichtlinie für die Gruppe CloudWatch Logs.
## Erstellen Sie den Connector
Im folgenden Abschnitt erstellen und implementieren Sie den [EventBridge Kafka-Sink-Connector](https://github.com/awslabs/eventbridge-kafka-connector) mithilfe des AWS-Managementkonsole.
**Topics**
+ [Schritt 1: Laden Sie den Connector herunter](#mkc-eb-kafka-download-connector)
+ [Schritt 2: Erstellen Sie einen Amazon S3 S3-Bucket](#mkc-eb-kafka-s3-bucket-create)
+ [Schritt 3: Erstellen Sie ein Plugin in MSK Connect](#mkc-eb-kafka-create-plugin)
+ [Schritt 4: Den Konnektor erstellen](#mkc-eb-kafka-create-connector)
### Schritt 1: Laden Sie den Connector herunter
Laden Sie das neueste EventBridge Connector-Sink-JAR von der [GitHub Releases-Seite](https://github.com/awslabs/eventbridge-kafka-connector/releases) für den EventBridge Kafka-Connector herunter. Um beispielsweise die Version v1.4.1 herunterzuladen, wählen Sie den Link zur JAR-Datei,`kafka-eventbridge-sink-with-dependencies.jar`, um den Connector herunterzuladen. Speichern Sie die Datei anschließend an einem bevorzugten Speicherort auf Ihrem Computer.
### Schritt 2: Erstellen Sie einen Amazon S3 S3-Bucket
1. Um die JAR-Datei in Amazon S3 zur Verwendung mit MSK Connect zu speichern, öffnen Sie die AWS-Managementkonsole und wählen Sie dann Amazon S3.
1. Wählen Sie in der Amazon S3 S3-Konsole **Bucket erstellen** und geben Sie einen eindeutigen Bucket-Namen ein. Beispiel, **amzn-s3-demo-bucket1-eb-connector**.
1. Wählen Sie eine geeignete Region für Ihren Amazon S3 S3-Bucket aus. Stellen Sie sicher, dass sie mit der Region übereinstimmt, in der Ihr MSK-Cluster bereitgestellt wird.
1. Behalten Sie bei den **Bucket-Einstellungen** die Standardauswahl bei oder passen Sie sie nach Bedarf an.
1. Wählen Sie **Bucket erstellen** aus
1. Laden Sie die JAR-Datei in den Amazon S3 S3-Bucket hoch.
### Schritt 3: Erstellen Sie ein Plugin in MSK Connect
1. Öffnen Sie die AWS-Managementkonsole, und navigieren Sie dann zu **MSK Connect**.
1. Wählen Sie im linken Navigationsbereich die Option **Benutzerdefinierte Plugins** aus.
1. Wählen Sie **Plugin erstellen** und geben Sie dann einen **Plugin-Namen** ein. Beispiel, **eventbridge-sink-plugin**.
1. Fügen Sie **unter Benutzerdefinierter Plugin-Speicherort** die **URL des S3-Objekts ein**.
1. Fügen Sie eine optionale Beschreibung für das Plugin hinzu.
1. Wählen Sie **Plugin erstellen**.
Nachdem das Plugin erstellt wurde, können Sie es verwenden, um den EventBridge Kafka-Konnektor in MSK Connect zu konfigurieren und bereitzustellen.
### Schritt 4: Den Konnektor erstellen
Bevor Sie den Konnektor erstellen, empfehlen wir, das erforderliche Kafka-Thema zu erstellen, um Konnektorfehler zu vermeiden. Verwenden Sie Ihren Client-Computer, um das Thema zu erstellen.
1. Wählen Sie im linken Bereich der MSK-Konsole **Connectors** und dann **Create Connector** aus.
1. Wählen Sie in der Liste der Plugins die Option **eventbridge-sink-plugin** und anschließend **Weiter**.
1. Geben **EventBridgeSink** Sie als Namen des Connectors ein.
1. Wählen Sie in der Clusterliste Ihren MSK-Cluster aus.
1. Kopieren Sie die folgende Konfiguration für den Connector und fügen Sie sie in das Feld **Connector-Konfiguration** ein
Ersetzen Sie die Platzhalter in der folgenden Konfiguration nach Bedarf.
+ Entfernen Sie`aws.eventbridge.endpoint.uri`, wenn Ihr MSK-Cluster über einen öffentlichen Internetzugang verfügt.
+ Wenn Sie eine sichere Verbindung von MSK PrivateLink zu verwenden EventBridge, ersetzen Sie den DNS-Teil danach `https://` durch den richtigen privaten DNS-Namen des (optionalen) VPC-Schnittstellenendpunkts EventBridge , den Sie zuvor erstellt haben.
+ Ersetzen Sie den EventBridge Event-Bus-ARN in der folgenden Konfiguration durch den ARN Ihres Event-Busses.
+ Aktualisieren Sie alle regionsspezifischen Werte.
```
{
"connector.class": "software.amazon.event.kafkaconnector.EventBridgeSinkConnector",
"aws.eventbridge.connector.id": "msk-eventbridge-tutorial",
"topics": "msk-eventbridge-tutorial",
"tasks.max": "1",
"aws.eventbridge.endpoint.uri": "https://events.us-east-1.amazonaws.com",
"aws.eventbridge.eventbus.arn": "arn:aws:events:us-east-1:123456789012:event-bus/example-event-bus",
"value.converter.schemas.enable": "false",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"aws.eventbridge.region": "us-east-1",
"auto.offset.reset": "earliest",
"key.converter": "org.apache.kafka.connect.storage.StringConverter"
}
```
Weitere Informationen zur Connectorkonfiguration finden Sie unter. [eventbridge-kafka-connector](https://github.com/awslabs/eventbridge-kafka-connector)
Ändern Sie bei Bedarf die Einstellungen für Worker und Autoscaling. Wir empfehlen außerdem, die neueste verfügbare (empfohlene) Apache Kafka Connect-Version aus der Drop-down-Liste zu verwenden. Verwenden **Sie unter Zugriffsberechtigungen** die zuvor erstellte Rolle. Aus Gründen der Beobachtbarkeit und Problembehandlung empfehlen wir außerdem, die Protokollierung zu CloudWatch aktivieren. Passen Sie die anderen optionalen Einstellungen, wie z. B. Tags, an Ihre Bedürfnisse an. Stellen Sie dann den Connector bereit und warten Sie, bis der Status in den Status Running übergeht.
## Senden Sie Nachrichten an Kafka
Sie können Nachrichtenkodierungen wie Apache Avro und JSON konfigurieren, indem Sie mithilfe der in Kafka Connect verfügbaren `key.converter` Einstellungen `value.converter` und, optional, verschiedene Konverter angeben.
Der [connector example](#connector-ex) in diesem Thema beschriebene ist so konfiguriert, dass er mit JSON-codierten Nachrichten funktioniert, wie durch die Verwendung von for angedeutet wird. `org.apache.kafka.connect.json.JsonConverter` `value converter` Wenn sich der Connector im Status Running befindet, senden Sie Datensätze von Ihrem Client-Computer aus an das `msk-eventbridge-tutorial` Kafka-Thema.