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.
# MSK-Serverless-Cluster verwenden
Dieses Tutorial zeigt Ihnen ein Beispiel dafür, wie Sie einen MSK-Serverless-Cluster erstellen, einen Client-Computer erstellen, der darauf zugreifen kann, und den Client verwenden, um Themen auf dem Cluster zu erstellen und Daten in diese Themen zu schreiben. Dieses Beispiel zeigt nicht alle Optionen, die Sie auswählen können, wenn Sie einen Serverless-Cluster erstellen. In verschiedenen Teilen dieses Tutorials wählen wir aus Gründen der Einfachheit die Standardoptionen. Dies bedeutet nicht, dass dies die einzigen Optionen sind, die funktionieren, um einen Serverless-Cluster einzurichten. Sie können auch die AWS CLI oder die Amazon MSK-API verwenden. Weitere Informationen finden Sie in der [Amazon-MSK-API-Referenz 2.0](https://docs.aws.amazon.com/MSK/2.0/APIReference/what-is-msk.html).
**Topics**
+ [Erstellen Sie einen MSK-Serverless-Cluster](create-serverless-cluster.md)
+ [Erstellen Sie eine IAM-Rolle für Themen im MSK Serverless Cluster](create-iam-role.md)
+ [Erstellen Sie einen Client-Computer für den Zugriff auf den MSK Serverless Cluster](create-serverless-cluster-client.md)
+ [Erstellen Sie ein Apache Kafka-Thema](msk-serverless-create-topic.md)
+ [Produzieren und konsumieren Sie Daten in MSK Serverless](msk-serverless-produce-consume.md)
+ [Löschen Sie Ressourcen, die Sie für MSK Serverless erstellt haben](delete-resources.md)
# Erstellen Sie einen MSK-Serverless-Cluster
In diesem Schritt führen Sie zwei Aufgaben aus. Zunächst erstellen Sie einen MSK-Serverless-Cluster mit Standardeinstellungen. Zweitens sammeln Sie Informationen über den Cluster. Diese Informationen benötigen Sie in späteren Schritten, wenn Sie einen Client erstellen, der Daten an den Cluster senden kann.
**So erstellen Sie einen Serverless-Cluster**
1. Melden Sie sich bei der AWS-Managementkonsole an und öffnen Sie die Amazon MSK-Konsole zu [https://console.aws.amazon.com/msk/Hause](https://console.aws.amazon.com/msk/home).
1. Wählen Sie **Cluster erstellen**.
1. Lassen Sie für die **Erstellungsmethode** die Option **Schnellerstellung** ausgewählt. Mit der Option **Schnellerstellung** können Sie einen Serverless-Cluster mit Standardeinstellungen erstellen.
1. Geben Sie für **Cluster-Name** einen beschreibenden Namen ein, z. B. **msk-serverless-tutorial-cluster**.
1. Wählen Sie für **Allgemeine Cluster-Eigenschaften** **Serverless** als **Cluster-Typ**. Verwenden Sie die Standardwerte für die übrigen **allgemeinen Cluster**-Eigenschaften.
1. Beachten Sie die Tabelle unter **Alle Cluster-Einstellungen**. In dieser Tabelle sind die Standardwerte für wichtige Einstellungen wie Netzwerk und Verfügbarkeit aufgeführt. Außerdem wird angegeben, ob Sie die einzelnen Einstellungen nach der Erstellung des Clusters ändern können. Um eine Einstellung zu ändern, bevor Sie den Cluster erstellen, sollten Sie unter **Erstellungsmethode** die Option **Benutzerdefiniertes Erstellen** auswählen.
**Anmerkung**
Mit MSK Serverless Clustern können Sie Clients aus bis zu fünf verschiedenen VPCs Netzwerken verbinden. Damit Client-Anwendungen bei einem Ausfall in eine andere Availability Zone wechseln können, müssen Sie in jeder VPC mindestens zwei Subnetze angeben.
1. Wählen Sie **Cluster erstellen**.
**So sammeln Sie Informationen über den Cluster**
1. Wählen Sie im Abschnitt mit der **Cluster-Zusammenfassung** die Option **Client-Informationen anzeigen**. Diese Schaltfläche bleibt ausgegraut, bis Amazon MSK die Erstellung des Clusters abgeschlossen hat. Möglicherweise müssen Sie einige Minuten warten, bis die Schaltfläche aktiv wird, sodass Sie sie verwenden können.
1. Kopieren Sie die Zeichenfolge unter der Bezeichnung **Endpunkt**. Dies ist Ihre Bootstrap-Server-Zeichenfolge.
1. Wählen Sie die Registerkarte **Eigenschaften** aus.
1. Kopieren Sie im Abschnitt **Netzwerkeinstellungen** die IDs Subnetze und die Sicherheitsgruppe und speichern Sie sie, da Sie diese Informationen später benötigen, um einen Client-Computer zu erstellen.
1. Wählen Sie eines der Subnetze aus. Dadurch wird die Amazon-VPC-Konsole geöffnet. Suchen Sie die ID der Amazon VPC, die dem Subnetz zugeordnet ist. Speichern Sie diese Amazon-VPC-ID zur späteren Verwendung.
**Nächster Schritt**
[Erstellen Sie eine IAM-Rolle für Themen im MSK Serverless Cluster](create-iam-role.md)
# Erstellen Sie eine IAM-Rolle für Themen im MSK Serverless Cluster
In diesem Schritt führen Sie zwei Aufgaben aus. Die erste Aufgabe besteht darin, eine IAM-Richtlinie zu erstellen, die Zugriff auf die Erstellung von Themen auf dem Cluster und das Senden von Daten an diese Themen gewährt. Die zweite Aufgabe besteht darin, eine IAM-Rolle zu erstellen und ihr diese Richtlinie zuzuordnen. In einem späteren Schritt erstellen wir einen Client-Computer, der diese Rolle übernimmt und sie verwendet, um ein Thema auf dem Cluster zu erstellen und Daten an dieses Thema zu senden.
**So erstellen Sie eine IAM-Richtlinie, die es ermöglicht, Themen zu erstellen und in sie zu schreiben**
1. Öffnen Sie unter [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/) die IAM-Konsole.
1. Wählen Sie im Navigationsbereich **Richtlinien**.
1. Wählen Sie **Richtlinie erstellen** aus.
1. Wählen Sie die Registerkarte **JSON** und ersetzen Sie dann den JSON-Code im Editor-Fenster durch den Folgenden.
Ersetzen Sie im folgenden Beispiel Folgendes:
+ *region*mit dem Code des Ortes AWS-Region , an dem Sie Ihren Cluster erstellt haben.
+ Beispiel für eine Konto-ID*123456789012*, mit Ihrer AWS-Konto ID.
+ *msk-serverless-tutorial-cluster*/*c07c74ea-5146-4a03-add1-9baa787a5b14-s3*und *msk-serverless-tutorial-cluster* mit Ihrer serverlosen Cluster-ID und Ihrem Themennamen.
------
#### [ JSON ]
****
```
{
"Version":"2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"kafka-cluster:Connect",
"kafka-cluster:DescribeCluster"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:cluster/msk-serverless-tutorial-cluster/c07c74ea-5146-4a03-add1-9baa787a5b14-s3"
]
},
{
"Effect": "Allow",
"Action": [
"kafka-cluster:CreateTopic",
"kafka-cluster:WriteData",
"kafka-cluster:DescribeTopic"
],
"Resource": [
"arn:aws:kafka:us-east-1:123456789012:topic/msk-serverless-tutorial-cluster/*"
]
}
]
}
```
------
Anweisungen zum Schreiben sicherer Richtlinien finden Sie unter[IAM-Zugriffssteuerung](iam-access-control.md).
1. Wählen Sie **Next: Tags** (Weiter: Tags) aus.
1. Klicken Sie auf **Weiter: Prüfen**.
1. Geben für den Richtliniennamen einen beschreibenden Namen ein, z. B. **msk-serverless-tutorial-policy**.
1. Wählen Sie **Richtlinie erstellen** aus.
**So erstellen Sie eine IAM-Rolle und fügen ihr die Richtlinie an**
1. Wählen Sie im Navigationsbereich **Rollen**.
1. Wählen Sie **Rolle erstellen**.
1. Wählen Sie unter **Häufige Anwendungsfälle** die Option **EC2** und dann **Weiter: Berechtigungen**.
1. Geben Sie in das Suchfeld den Namen der Richtlinie ein, die Sie zuvor für dieses Tutorial erstellt haben. Aktivieren Sie anschließend das Kontrollkästchen links neben der Richtlinie.
1. Wählen Sie **Next: Tags** (Weiter: Tags) aus.
1. Klicken Sie auf **Weiter: Prüfen**.
1. Geben Sie für den Rollennamen einen beschreibenden Namen ein, z. B. **msk-serverless-tutorial-role**.
1. Wählen Sie **Rolle erstellen** aus.
**Nächster Schritt**
[Erstellen Sie einen Client-Computer für den Zugriff auf den MSK Serverless Cluster](create-serverless-cluster-client.md)
# Erstellen Sie einen Client-Computer für den Zugriff auf den MSK Serverless Cluster
In diesem Schritt führen Sie zwei Aufgaben aus. Die erste Aufgabe besteht darin, eine Amazon-EC2-Instance zu erstellen, die als Apache-Kafka-Client-Computer verwendet werden soll. Die zweite Aufgabe besteht darin, Java- und Apache-Kafka-Tools auf dem Computer zu installieren.
**Erstellen eines Client-Computers**
1. Öffnen Sie die Amazon-EC2-Konsole unter [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/).
1. Wählen Sie **Launch Instance (Instance starten)** aus.
1. Geben Sie einen beschreibenden **Namen** für Ihren Client-Computer ein, z. B. **msk-serverless-tutorial-client**
1. Lassen Sie **Amazon Linux 2 AMI (HVM) – Kernel 5.10, SSD Volume Type** als **Amazon Machine Image (AMI)-Typ** ausgewählt.
1. Lassen Sie den **t2.micro**-Instance-Typ ausgewählt.
1. Wählen Sie unter **Schlüsselpaar (Login)** die Option **Neues Schlüsselpaar erstellen**. Geben Sie **MSKServerlessKeyPair** für **Schlüsselpaar-Name** ein. Wählen Sie dann **Schlüsselpaar herunterladen**. Alternativ können Sie ein vorhandenes Schlüsselpaar verwenden.
1. Wählen Sie für **Netzwerkeinstellungen** die Option **Bearbeiten** aus.
1. Geben Sie unter **VPC** die ID der Virtual Private Cloud (VPC) für Ihren Serverless-Cluster ein. Dies ist die VPC, die auf dem Amazon-VPC-Service basiert und dessen ID Sie nach der Erstellung des Clusters gespeichert haben.
1. Wählen Sie für **Subnetz** das Subnetz aus, dessen ID Sie nach der Erstellung des Clusters gespeichert haben.
1. Wählen Sie unter **Firewall (Sicherheitsgruppen)** die Sicherheitsgruppe aus, die dem Cluster zugeordnet ist. Dieser Wert funktioniert, wenn diese Sicherheitsgruppe über eine eingehende Regel verfügt, die Datenverkehr von der Sicherheitsgruppe zu sich selbst zulässt. Mit einer solchen Regel können Mitglieder derselben Sicherheitsgruppe miteinander kommunizieren. Weitere Informationen finden Sie unter [Sicherheitsgruppenregeln](https://docs.aws.amazon.com/vpc/latest/userguide/VPC_SecurityGroups.html#SecurityGroupRules) im Amazon-VPC-Benutzerhandbuch.
1. Erweitern Sie den Abschnitt **Erweiterte Details** und wählen Sie die IAM-Rolle aus, die Sie in [Erstellen Sie eine IAM-Rolle für Themen im MSK Serverless Cluster](create-iam-role.md) erstellt haben.
1. Wählen Sie **Launch** (Starten) aus.
1. Wählen Sie im linken Navigationsbereich die Option **Instances** aus. Aktivieren Sie dann das Kontrollkästchen in der Zeile, die die neu erstellte Amazon-EC2-Instance darstellt. Ab diesem Zeitpunkt nennen wir diese Instance den *Client-Computer*.
1. Wählen Sie **Verbinden** und folgen Sie den Anweisungen, um eine Verbindung zum Client-Computer herzustellen.
**So richten Sie die Apache-Kafka-Client-Tools auf dem Client-Computer ein**
1. Installieren Sie Java auf dem Client-Computer, indem Sie den folgenden Befehl ausführen:
```
sudo yum -y install java-11
```
1. Führen Sie die folgenden Befehle aus, um die Apache-Kafka-Tools zu erhalten, die wir zum Erstellen von Themen und zum Senden von Daten benötigen:
```
wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz
```
```
tar -xzf kafka_2.12-2.8.1.tgz
```
**Anmerkung**
Stellen Sie nach dem Extrahieren des Kafka-Archivs sicher, dass die Skripts im `bin` Verzeichnis über die erforderlichen Ausführungsberechtigungen verfügen. Führen Sie dazu den folgenden Befehl aus.
```
chmod +x kafka_2.12-2.8.1/bin/*.sh
```
1. Wechseln Sie zum Verzeichnis `kafka_2.12-2.8.1/libs` und führen Sie dann den folgenden Befehl aus, um die Amazon-MSK-IAM-JAR-Datei herunterzuladen. Das Amazon-MSK-IAM-JAR ermöglicht dem Client-Computer den Zugriff auf den Cluster.
```
wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar
```
Mit diesem Befehl können Sie auch [andere oder neuere Versionen der Amazon MSK IAM JAR-Datei herunterladen](https://github.com/aws/aws-msk-iam-auth/releases).
1. Wechseln Sie zum Verzeichnis `kafka_2.12-2.8.1/bin`. Kopieren Sie die folgenden Eigenschaften-Einstellungen und fügen Sie sie in eine neue Datei ein. Benennen Sie die Datei `client.properties` und speichern Sie sie.
```
security.protocol=SASL_SSL
sasl.mechanism=AWS_MSK_IAM
sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required;
sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
```
**Nächster Schritt**
[Erstellen Sie ein Apache Kafka-Thema](msk-serverless-create-topic.md)
# Erstellen Sie ein Apache Kafka-Thema
In diesem Schritt verwenden Sie den zuvor erstellten Client-Computer, um ein Thema auf dem Serverless-Cluster zu erstellen.
**Topics**
+ [Richten Sie Ihre Umgebung für die Erstellung von Themen ein](#msk-serverless-create-topic-prerequisites)
+ [Ein Thema erstellen und Daten dazu schreiben](#msk-serverless-create-topic-procedure)
## Richten Sie Ihre Umgebung für die Erstellung von Themen ein
+ Bevor Sie ein Thema erstellen, stellen Sie sicher, dass Sie die AWS MSK IAM JAR-Datei in das Verzeichnis Ihrer Kafka-Installation heruntergeladen haben. `libs/` Wenn Sie dies noch nicht getan haben, führen Sie den folgenden Befehl in Ihrem Kafka-Verzeichnis aus. `libs/`
```
wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar
```
Diese JAR-Datei ist für die IAM-Authentifizierung mit Ihrem MSK Serverless-Cluster erforderlich.
+ Wenn Sie Kafka-Befehle ausführen, müssen Sie möglicherweise sicherstellen, dass die AWS MSK `classpath` IAM-JAR-Datei enthalten ist. Führen Sie dazu einen der folgenden Schritte aus:
+ Stellen Sie die `CLASSPATH` Umgebungsvariable so ein, dass sie Ihre Kafka-Bibliotheken einschließt, wie im folgenden Beispiel gezeigt.
```
export CLASSPATH=/libs/*:/libs/aws-msk-iam-auth-2.3.0-all.jar
```
+ Führen Sie Kafka-Befehle mit dem vollständigen Java-Befehl mit explicit aus`classpath`, wie im folgenden Beispiel gezeigt.
```
java -cp "/libs/*:/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.TopicCommand --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6
```
## Ein Thema erstellen und Daten dazu schreiben
1. Ersetzen Sie im folgenden `export` Befehl *my-endpoint* durch die Bootstrap-Server-Zeichenfolge, die Sie nach der Erstellung des Clusters gespeichert haben. Wechseln Sie dann zum Verzeichnis `kafka_2.12-2.8.1/bin` auf dem Client-Computer und führen Sie den `export`-Befehl aus.
```
export BS=my-endpoint
```
1. Führen Sie den folgenden Befehl aus, um ein Thema mit dem Namen `msk-serverless-tutorial` zu erstellen.
```
/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6
```
**Nächster Schritt**
[Produzieren und konsumieren Sie Daten in MSK Serverless](msk-serverless-produce-consume.md)
# Produzieren und konsumieren Sie Daten in MSK Serverless
In diesem Schritt produzieren und verbrauchen Sie Daten mithilfe des Themas, das Sie im vorherigen Schritt erstellt haben.
**Erstellen und Verbrauchen von Nachrichten**
1. Führen Sie den folgenden Befehl aus, um einen Konsolenproduzenten zu erstellen.
```
/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial
```
1. Geben Sie eine beliebige Nachricht ein, und drücken Sie **Enter (Eingabetaste)**. Wiederholen Sie diesen Schritt zwei- oder dreimal. Jedes Mal, wenn Sie eine Zeile eingeben und **Eingabe** drücken, wird diese Zeile als separate Nachricht an Ihren Apache-Kafka-Cluster gesendet.
1. Lassen Sie die Verbindung zum Client-Computer geöffnet und öffnen Sie dann eine zweite separate Verbindung zu diesem Computer in einem neuen Fenster.
1. Verwenden Sie Ihre zweite Verbindung zum Client-Computer, um mit dem folgenden Befehl einen Konsolen-Verbraucher zu erstellen. *my-endpoint*Ersetzen Sie es durch die Bootstrap-Serverzeichenfolge, die Sie nach der Erstellung des Clusters gespeichert haben.
```
/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --from-beginning
```
Sie sehen die Nachrichten, die Sie zuvor eingegeben haben, als Sie den Konsolenproduzentenbefehl verwendet haben.
1. Geben Sie weitere Nachrichten in das Producer-Fenster ein und beobachten Sie, wie sie im Consumer-Fenster angezeigt werden.
Wenn bei der Ausführung dieser Befehle `classpath` Probleme auftreten, stellen Sie sicher, dass Sie sie im richtigen Verzeichnis ausführen. Stellen Sie außerdem sicher, dass sich das AWS MSK IAM-JAR im `libs` Verzeichnis befindet. Alternativ können Sie Kafka-Befehle mit dem vollständigen Java-Befehl mit explicit ausführen`classpath`, wie im folgenden Beispiel gezeigt.
```
java -cp "kafka_2.12-2.8.1/libs/*:kafka_2.12-2.8.1/libs/aws-msk-iam-auth-2.3.0-all.jar" org.apache.kafka.tools.ConsoleProducer —broker-list $BS —producer.config client.properties —topic msk-serverless-tutorial
```
**Nächster Schritt**
[Löschen Sie Ressourcen, die Sie für MSK Serverless erstellt haben](delete-resources.md)
# Löschen Sie Ressourcen, die Sie für MSK Serverless erstellt haben
In diesem Schritt löschen Sie die Ressourcen, die Sie in diesem Tutorial erstellt haben.
**So löschen Sie den Cluster**
1. Öffnen Sie die Amazon MSK-Konsole zu [https://console.aws.amazon.com/msk/Hause](https://console.aws.amazon.com/msk/home).
1. Wählen Sie in der Liste der Cluster den Cluster aus, den Sie für dieses Tutorial erstellt haben.
1. Wählen Sie für **Aktionen** die Option **Cluster löschen**.
1. Geben Sie `delete` in das Feld ein und wählen Sie dann **Löschen**.
**So stoppen Sie den Client-Computer**
1. Öffnen Sie die Amazon-EC2-Konsole unter [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/).
1. Wählen Sie in der Liste der Amazon-EC2-Instances den Client-Computer aus, den Sie für dieses Tutorial erstellt haben.
1. Wählen Sie **Instance-Status** und dann **Instance beenden**.
1. Wähen Sie **Beenden**.
**So löschen Sie die IAM-Richtlinie und -Rolle**
1. Öffnen Sie unter [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/) die IAM-Konsole.
1. Wählen Sie im Navigationsbereich **Rollen**.
1. Geben Sie in das Suchfeld den Namen der IAM-Rolle ein, die Sie für dieses Tutorial erstellt haben.
1. Wählen Sie die Rolle aus. Wählen Sie dann **Rolle löschen** und bestätigen Sie das Löschen.
1. Wählen Sie im Navigationsbereich **Richtlinien**.
1. Geben Sie in das Suchfeld den Namen der Richtlinie ein, die Sie für dieses Tutorial erstellt haben.
1. Wählen Sie die Richtlinie aus, um die zugehörige Übersichtsseite zu öffnen. Wählen Sie auf der **Übersicht**-Seite der Richtlinie die Option **Richtlinie löschen**.
1. Wählen Sie **Löschen** aus.