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. # Erste Schritte mit Amazon MSK In diesem Tutorial sehen Sie ein Beispiel, wie Sie mithilfe von Metriken einen MSK-Cluster erstellen, Daten erzeugen und verbrauchen und den Zustand Ihres Clusters überwachen können. Dieses Beispiel zeigt nicht alle Optionen, die Sie auswählen können, wenn Sie einen MSK-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, um einen MSK-Cluster oder Client-Instances einzurichten. **Topics** + [ # Schritt 1: Erstellen Sie einen von MSK bereitgestellten Cluster ](create-cluster.md) + [ # Schritt 2: Erstellen Sie eine IAM-Rolle, die Zugriff auf die Erstellung von Themen im Amazon MSK-Cluster gewährt ](create-client-iam-role.md) + [ # Schritt 3: Einen Client-Computer erstellen ](create-client-machine.md) + [ # Schritt 4: Erstellen Sie ein Thema im Amazon MSK-Cluster ](create-topic.md) + [ # Schritt 5: Produzieren und Verbrauchen von Daten ](produce-consume.md) + [ # Schritt 6: Amazon CloudWatch zum Anzeigen von Amazon MSK-Metriken verwenden ](view-metrics.md) + [ # Schritt 7: Löschen Sie die für dieses Tutorial erstellten AWS Ressourcen ](delete-cluster.md) # Schritt 1: Erstellen Sie einen von MSK bereitgestellten Cluster In diesem Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) erstellen Sie einen von Amazon MSK bereitgestellten Cluster. Sie verwenden die Option **Quick Create** in, um diesen Cluster AWS-Managementkonsole zu erstellen. **So erstellen Sie einen Amazon MSK-Cluster mit dem AWS-Managementkonsole**Erstellen Sie einen Cluster mit dem AWS-Managementkonsole 1. Melden Sie sich bei der AWS-Managementkonsole an und öffnen Sie die Amazon MSK-Konsole zu [https://console.aws.amazon.com/msk/Hause? region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/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 Cluster mit Standardeinstellungen erstellen. 1. Geben Sie unter **Cluster-Name** einen Namen für den Cluster ein. Beispiel, **MSKTutorialCluster**. 1. **Gehen Sie für Allgemeine Clustereigenschaften wie folgt vor:** 1. Wählen Sie als **Clustertyp** die Option **Bereitgestellt aus.** 1. Wählen Sie eine **Apache Kafka-Version** aus, die auf den Brokern ausgeführt werden soll. Wählen Sie **Versionskompatibilität anzeigen**, um eine Vergleichstabelle anzuzeigen. 1. Wählen Sie als **Brokertyp** entweder Standard- oder Express-Broker aus. 1. Wählen Sie eine **Broker-Größe**. 1. Kopieren Sie aus der Tabelle unter **Alle Cluster-Einstellungen** die Werte der folgenden Einstellungen und speichern Sie sie, da Sie sie später in diesem Tutorial benötigen: + VPC + Subnets + Die mit der VPC verknüpften Sicherheitsgruppen 1. Wählen Sie **Cluster erstellen**. 1. Überprüfen Sie den Cluster-**Status** auf der Seite **Cluster-Zusammenfassung**. Der Status ändert sich von **Erstellen** auf **Aktiv**, wenn Amazon MSK den Cluster bereitstellt. Wenn der Status **Active** lautet, können Sie die Verbindung mit dem Cluster herstellen. Weitere Informationen zu Cluster-Status finden Sie unter [Verstehen Sie die Status des MSK Provisioned Clusters](msk-cluster-states.md). **Nächster Schritt** [Schritt 2: Erstellen Sie eine IAM-Rolle, die Zugriff auf die Erstellung von Themen im Amazon MSK-Cluster gewährt](create-client-iam-role.md) # Schritt 2: Erstellen Sie eine IAM-Rolle, die Zugriff auf die Erstellung von Themen im Amazon MSK-Cluster gewährt 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 Sie 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**Eine IAM-Richtlinie erstellen 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 im **Richtlinieneditor** **JSON** aus und ersetzen Sie dann das JSON im Editorfenster durch das folgende JSON. 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. + *MSKTutorialCluster*und*MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14*, mit dem Namen Ihres Clusters und seiner ID. ------ #### [ JSON ] **** ``` { "Version":"2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "kafka-cluster:Connect", "kafka-cluster:AlterCluster", "kafka-cluster:DescribeCluster" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:cluster/MSKTutorialCluster/7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14" ] }, { "Effect": "Allow", "Action": [ "kafka-cluster:*Topic*", "kafka-cluster:WriteData", "kafka-cluster:ReadData" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:topic/MSKTutorialCluster/*" ] }, { "Effect": "Allow", "Action": [ "kafka-cluster:AlterGroup", "kafka-cluster:DescribeGroup" ], "Resource": [ "arn:aws:kafka:us-east-1:123456789012:group/MSKTutorialCluster/*" ] } ] } ``` ------ Anweisungen zum Schreiben sicherer Richtlinien finden Sie unter[IAM-Zugriffssteuerung](iam-access-control.md). 1. Wählen Sie **Weiter** aus. 1. Gehen Sie auf der Seite **Überprüfen und erstellen** wie folgt vor: 1. Geben Sie als **Richtlinienname** einen aussagekräftigen Namen ein, z. B. **msk-tutorial-policy** 1. Unter **In dieser Richtlinie definierte Berechtigungen** finden Sie weitere Informationen and/or zu den in Ihrer Richtlinie definierten Berechtigungen. 1. (Optional) Um die Richtlinie leichter zu identifizieren, zu organisieren oder nach ihr zu suchen, wählen Sie **Neues Tag hinzufügen** aus, um Stichwörter als Schlüssel-Wert-Paare hinzuzufügen. Fügen Sie Ihrer Richtlinie beispielsweise ein Tag mit dem Schlüssel-Wert-Paar und hinzu. **Environment** **Test** Weitere Informationen zur Verwendung von Tags finden Sie unter [Tags für AWS Identity and Access Management Ressourcen](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) im *IAM-Benutzerhandbuch*. 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** und anschließend **Rolle erstellen** aus. 1. Gehen Sie auf der Seite **Select trusted entity** (Vertrauenswürdige Entität auswählen) wie folgt vor: 1. Wählen Sie für **Vertrauenswürdige Entität** die Option **AWS-Service** aus. 1. Wählen Sie für **Service oder Anwendungsfall** **EC2** aus. 1. Wählen Sie unter **Use case** (Anwendungsfall) die Option **EC2** aus. 1. Wählen Sie **Next (Weiter)**. 1. Gehen Sie auf der Seite **Berechtigungen hinzufügen** wie folgt vor: 1. Geben Sie im Suchfeld unter **Berechtigungsrichtlinien** den Namen der Richtlinie ein, die Sie zuvor für dieses Tutorial erstellt haben. Wählen Sie dann das Feld links neben dem Richtliniennamen aus. 1. (Optional) Legen Sie eine [Berechtigungsgrenze](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html) fest. Dies ist ein erweitertes Feature, das für Servicerollen verfügbar ist, aber nicht für servicegebundene Rollen. Informationen zum Festlegen einer Berechtigungsgrenze finden Sie unter [Rollen erstellen und Richtlinien anhängen (Konsole)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html) im *IAM-Benutzerhandbuch*. 1. Wählen Sie **Weiter** aus. 1. Gehen Sie auf der Seite **Name, review, and create** (Benennen, überprüfen und erstellen) wie folgt vor: 1. Geben Sie **unter Rollenname** einen aussagekräftigen Namen ein, z. B. **msk-tutorial-role** **Wichtig** Beachten Sie beim Benennen einer Rolle Folgendes: Rollennamen müssen innerhalb Ihres AWS-Konto Unternehmens eindeutig sein und können nicht von Fall zu Fall eindeutig sein. Erstellen Sie beispielsweise keine Rollen mit dem Namen **PRODROLE** und **prodrole**. Wenn ein Rollenname in einer Richtlinie oder als Teil einer ARN verwendet wird, muss die Groß-/Kleinschreibung des Rollennamens beachtet werden. Wenn ein Rollenname den Kunden jedoch in der Konsole angezeigt wird, z. B. während des Anmeldevorgangs, wird die Groß-/Kleinschreibung des Rollennamens nicht beachtet. Sie können den Namen der Rolle nach ihrer Erstellung nicht mehr bearbeiten, da andere Entitäten möglicherweise auf die Rolle verweisen. 1. (Optional) Geben Sie unter **Beschreibung** eine Beschreibung für die neue Rolle ein. 1. (Optional) Um die Anwendungsfälle und Berechtigungen für die Rolle zu bearbeiten, wählen Sie in **Schritt 1: Vertrauenswürdige Entitäten auswählen** oder **Schritt 2: Abschnitte mit Berechtigungen hinzufügen** die Option **Bearbeiten** aus. 1. (Optional) Um die Rolle leichter zu identifizieren, zu organisieren oder nach ihr zu suchen, wählen Sie **Neues Tag hinzufügen** aus, um Tags als Schlüssel-Wert-Paare hinzuzufügen. Fügen Sie Ihrer Rolle beispielsweise ein Tag mit dem Schlüssel-Wert-Paar und hinzu. **ProductManager** **John** Weitere Informationen zur Verwendung von Tags finden Sie unter [Tags für AWS Identity and Access Management Ressourcen](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) im *IAM-Benutzerhandbuch*. 1. Prüfen Sie die Rolle und klicken Sie dann auf **Create Role (Rolle erstellen)**. **Nächster Schritt** [Schritt 3: Einen Client-Computer erstellen](create-client-machine.md) # Schritt 3: Einen Client-Computer erstellen In diesem Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) erstellen Sie einen Client-Computer. Sie verwenden diesen Client-Computer, um ein Thema zu erstellen, das Daten erzeugt und verwendet. Der Einfachheit halber erstellen Sie diesen Client-Computer in der VPC, die dem MSK-Cluster zugeordnet ist, sodass der Client problemlos eine Verbindung zum Cluster herstellen kann. **Erstellen eines Client-Computers**Erstellen Sie einen 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 im Dashboard der Amazon EC2-Konsole die Option **Instance starten** aus. 1. Geben Sie unter **Name und Tags** für **Name** einen aussagekräftigen Namen für Ihren Client-Computer ein, damit Sie ihn leicht verfolgen können. Beispiel, **MSKTutorialClient**. 1. Wählen Sie unter **Anwendungs- und Betriebssystem-Images (Amazon Machine Image)** **für Amazon Machine Image (AMI)** **Amazon Linux 2 AMI (HVM) — Kernel 5.10, SSD Volume** Type aus. 1. **Behalten Sie als **Instance-Typ** die Standardauswahl t2.micro bei.** 1. Wählen Sie unter **key pair (Anmeldung)** ein vorhandenes Schlüsselpaar aus oder erstellen Sie ein neues. Wenn Sie kein key pair benötigen, um eine Verbindung zu Ihrer Instance herzustellen, können Sie **Proceed without a key pair (nicht empfohlen)** wählen. Wenn Sie ein neues Schlüsselpaar erstellen möchten, führen Sie die folgenden Schritte aus: 1. Wählen Sie **Neues key pair erstellen**. 1. Geben Sie für **Key pair name** (Schlüsselpaar-Name) **MSKKeyPair** ein. 1. Behalten Sie für **Schlüsselpaartyp** und **Dateiformat mit privatem Schlüssel** die Standardauswahlen bei. 1. Wählen Sie **Create Key Pair (Schlüsselpaar erstellen)** aus. Alternativ können Sie ein vorhandenes Schlüsselpaar verwenden. 1. Scrollen Sie auf der Seite nach unten und erweitern Sie den Abschnitt **Erweiterte Details**. Gehen Sie dann wie folgt vor: 1. Wählen Sie für das **IAM-Instanzprofil** eine IAM-Rolle aus, die der Client-Computer übernehmen soll. Wenn Sie keine IAM-Rolle haben, gehen Sie wie folgt vor: 1. Wählen Sie **Neues IAM-Profil erstellen** aus. 1. Führen Sie die in [Schritt 2: Eine IAM-Rolle erstellen](create-client-iam-role.md) genannten Schritte aus. 1. Wählen Sie **Launch Instance (Instance starten)** aus. 1. Klicken Sie auf **View Instances (Instances anzeigen)**. Wählen Sie dann in der Spalte **Sicherheitsgruppen** die Sicherheitsgruppe, die Ihrer neuen Instance zugeordnet ist. Kopieren Sie die ID der Sicherheitsgruppe, und speichern Sie sie für später. 1. Öffnen Sie die Amazon-VPC-Konsole unter [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/). 1. Wählen Sie im Navigationsbereich **Security Groups (Sicherheitsgruppen)** aus. Suchen Sie die Sicherheitsgruppe, deren ID Sie in [Schritt 1: Erstellen Sie einen von MSK bereitgestellten Cluster](create-cluster.md) gespeichert haben. 1. Wählen Sie auf der Registerkarte **Regeln für eingehenden Datenverkehr** die Option **Regeln für eingehenden Datenverkehr bearbeiten**. 1. Wählen Sie **Regel hinzufügen** aus. 1. Wählen Sie in der neuen Regel **All traffic (Gesamter Datenverkehr)** in der Spalte **Type (Typ)**. Wählen Sie im zweiten Feld in der Spalte **Quelle** die Sicherheitsgruppe des Client-Computers. Dies ist die Gruppe, deren Namen Sie gespeichert haben, nachdem Sie die Client-Computer-Instance gestartet haben. 1. Wählen Sie **Regeln speichern** aus. Jetzt kann die Sicherheitsgruppe des Clusters Datenverkehr akzeptieren, der von der Sicherheitsgruppe des Client-Computers stammt. **Nächster Schritt** [Schritt 4: Erstellen Sie ein Thema im Amazon MSK-Cluster](create-topic.md) # Schritt 4: Erstellen Sie ein Thema im Amazon MSK-Cluster In diesem Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) können Sie ein Thema mit einem von zwei Ansätzen erstellen: Verwenden systemeigener AWS Tools mit der CreateTopic API oder Verwenden von Apache AdminClient Kafka-Tools auf einem Client-Computer. **Warnung** Wenn Sie AWS Tools mit der CreateTopic API verwenden, stellen Sie sicher, dass Ihr Cluster die Anforderungen erfüllt. Einzelheiten finden Sie unter [Anforderungen für die Verwendung des Themas APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements). **Warnung** Bei der Verwendung dieses AdminClient Ansatzes sind die in diesem Tutorial verwendeten Versionsnummern von Apache Kafka nur Beispiele. Es wird empfohlen, dieselbe Version des Clients wie die MSK-Cluster-Version zu verwenden. In einer älteren Client-Version fehlen möglicherweise bestimmte Funktionen und kritische Bugfixes. **Topics** + [ ## Ein Thema mithilfe von AWS Tools erstellen ](#create-topic-aws-tools) + [ ## Ermitteln Sie Ihre MSK-Cluster-Version ](#find-msk-cluster-version) + [ ## Ein Thema auf dem Client-Computer erstellen ](#create-topic-client-machine) ## Ein Thema mithilfe von AWS Tools erstellen Sie können Themen in Ihrem MSK-Cluster mithilfe von AWS Tools wie der AWS CLI oder der AWS Management Console erstellen. AWS SDKs Dieser Ansatz bietet eine optimierte Methode zur Verwaltung von Themen, ohne dass ein direkter Zugriff auf die Kafka-Client-Tools erforderlich ist. Ausführliche Informationen zum Erstellen von Themen mithilfe der AWS Tools finden Sie im [CreateTopic API-Entwicklerhandbuch](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html). ## Ermitteln Sie Ihre MSK-Cluster-Version 1. Öffnen Sie die Amazon-MSK-Konsole unter [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Wählen Sie in der Navigationsleiste die Region aus, in der Sie den MSK-Cluster erstellt haben. 1. Wählen Sie den MSK-Cluster aus. 1. Notieren Sie sich die Version von Apache Kafka, die auf dem Cluster verwendet wird. 1. Ersetzen Sie die Amazon-MSK-Versionsnummern in diesem Tutorial durch die in Schritt 3 erhaltene Version. ## Ein Thema auf dem Client-Computer erstellen 1. **Connect zu Ihrem Client-Computer her.** 1. Öffnen Sie die Amazon-EC2-Konsole unter [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Wählen Sie im Navigationsbereich **Instances** aus. Aktivieren Sie dann das Kontrollkästchen neben dem Namen des Client-Computers, auf dem Sie ihn erstellt haben[Schritt 3: Einen Client-Computer erstellen](create-client-machine.md). 1. Klicken Sie auf **Actions (Aktionen)** und anschließend auf **Connect (Verbinden)**. Folgen Sie den Anweisungen in der Konsole, um eine Verbindung zum Client-Computer herzustellen. 1. **Installieren Sie Java und richten Sie die Umgebungsvariable Kafka-Version ein.** 1. Installieren Sie Java auf dem Client-Computer, indem Sie den folgenden Befehl ausführen. ``` sudo yum -y install java-11 ``` 1. Speichern Sie die [Kafka-Version](#find-msk-cluster-version) Ihres MSK-Clusters in der Umgebungsvariablen`KAFKA_VERSION`, wie im folgenden Befehl gezeigt. Sie benötigen diese Informationen während des gesamten Setups. ``` export KAFKA_VERSION={KAFKA VERSION} ``` Wenn Sie beispielsweise Version 3.6.0 verwenden, verwenden Sie den folgenden Befehl. ``` export KAFKA_VERSION=3.6.0 ``` 1. **Laden Sie Apache Kafka herunter und entpacken Sie es.** 1. Führen Sie den folgenden Befehl aus, um Apache Kafka herunterzuladen. ``` wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` **Anmerkung** Die folgende Liste enthält einige alternative Kafka-Download-Informationen, die Sie verwenden können, falls Probleme auftreten. Wenn Sie Verbindungsprobleme haben oder eine Mirror-Site verwenden möchten, versuchen Sie es mit dem Apache-Mirror-Selektor, wie im folgenden Befehl gezeigt. ``` wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` Laden Sie eine entsprechende Version direkt von der [Apache Kafka-Website](https://kafka.apache.org/downloads) herunter. 1. Führen Sie den folgenden Befehl in dem Verzeichnis aus, in das Sie im vorherigen Schritt die TAR-Datei heruntergeladen haben. ``` tar -xzf kafka_2.13-$KAFKA_VERSION.tgz ``` 1. Speichern Sie den vollständigen Pfad zum neu erstellten Verzeichnis in der `KAFKA_ROOT` Umgebungsvariablen. ``` export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION ``` 1. **Richten Sie die Authentifizierung für Ihren MSK-Cluster ein.** 1. [Finden Sie die neueste Version](https://github.com/aws/aws-msk-iam-auth/releases/latest) der Amazon MSK IAM-Clientbibliothek. Diese Bibliothek ermöglicht Ihrem Client-Computer den Zugriff auf den MSK-Cluster mithilfe der IAM-Authentifizierung. 1. Navigieren Sie mit den folgenden Befehlen zu dem `$KAFKA_ROOT/libs` Verzeichnis und laden Sie das zugehörige Amazon MSK IAM-JAR herunter, das Sie im vorherigen Schritt gefunden haben. Stellen Sie sicher, dass Sie es *\$1LATEST VERSION\$1* durch die tatsächliche Versionsnummer ersetzen, die Sie herunterladen. ``` cd $KAFKA_ROOT/libs ``` ``` wget https://github.com/aws/aws-msk-iam-auth/releases/latest/download/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` **Anmerkung** Bevor Sie irgendwelche Kafka-Befehle ausführen, die mit Ihrem MSK-Cluster interagieren, müssen Sie möglicherweise die Amazon MSK IAM JAR-Datei zu Ihrem Java-Klassenpfad hinzufügen. Stellen Sie die `CLASSPATH` Umgebungsvariable ein, wie im folgenden Beispiel gezeigt. ``` export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` Dadurch wird die `CLASSPATH` für Ihre gesamte Sitzung festgelegt, sodass die JAR für alle nachfolgenden Kafka-Befehle verfügbar ist. 1. Gehen Sie in das `$KAFKA_ROOT/config` Verzeichnis, um die Client-Konfigurationsdatei zu erstellen. ``` cd $KAFKA_ROOT/config ``` 1. Kopieren Sie die folgenden Eigenschaften-Einstellungen und fügen Sie sie in eine neue Datei ein. Speichern Sie die Datei als **client.properties**. ``` 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 ``` 1. **(Optional) Passen Sie die Java-Heap-Größe für Kafka-Tools an.** Wenn Sie auf Speicherprobleme stoßen oder mit einer großen Anzahl von Themen oder Partitionen arbeiten, können Sie die Java-Heap-Größe anpassen. Stellen Sie dazu die `KAFKA_HEAP_OPTS` Umgebungsvariable ein, bevor Sie Kafka-Befehle ausführen. Im folgenden Beispiel werden sowohl die maximale als auch die anfängliche Heap-Größe auf 512 Megabyte festgelegt. Passen Sie diese Werte an Ihre spezifischen Anforderungen und verfügbaren Systemressourcen an. ``` export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M" ``` 1. **Rufen Sie Ihre Cluster-Verbindungsinformationen ab.** 1. Öffnen Sie die Amazon-MSK-Konsole unter [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Warten Sie, bis der Status Ihres Clusters **Aktiv** ist. Dies kann einige Minuten dauern. Wenn der Status **Aktiv** lautet, wählen Sie den Cluster-Namen aus. Dadurch gelangen Sie zu einer Seite mit der Cluster-Zusammenfassung. 1. Wählen Sie **Client-Informationen anzeigen**. 1. Kopieren Sie die Verbindungszeichenfolge für den privaten Endpunkt. Sie erhalten drei Endpunkte für jeden der Broker. Speichern Sie eine dieser Verbindungszeichenfolgen in der Umgebungsvariablen`BOOTSTRAP_SERVER`, wie im folgenden Befehl gezeigt. **Ersetzen Sie durch den tatsächlichen Wert der Verbindungszeichenfolge. ``` export BOOTSTRAP_SERVER= ``` 1. **Führen Sie den folgenden Befehl aus, um das Thema zu erstellen.** ``` $KAFKA_ROOT/bin/kafka-topics.sh --create --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic ``` Wenn Sie eine `NoSuchFileException` für die `client.properties` Datei erhalten, stellen Sie sicher, dass diese Datei im aktuellen Arbeitsverzeichnis innerhalb des Kafka-Verzeichnisses bin existiert. **Anmerkung** Wenn Sie es vorziehen, die `CLASSPATH` Umgebungsvariable nicht für Ihre gesamte Sitzung festzulegen, können Sie alternativ jedem Kafka-Befehl die `CLASSPATH` Variable voranstellen. Bei diesem Ansatz wird der Klassenpfad nur auf diesen speziellen Befehl angewendet. ``` CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar \ $KAFKA_ROOT/bin/kafka-topics.sh --create \ --bootstrap-server $BOOTSTRAP_SERVER \ --command-config $KAFKA_ROOT/config/client.properties \ --replication-factor 3 \ --partitions 1 \ --topic MSKTutorialTopic ``` 1. **(Optional) Vergewissern Sie sich, dass das Thema erfolgreich erstellt wurde.** 1. Wenn der Befehl erfolgreich ist, sollte die folgende Meldung angezeigt werden: `Created topic MSKTutorialTopic.` 1. Listen Sie alle Themen auf, um zu bestätigen, dass Ihr Thema existiert. ``` $KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties ``` Wenn der Befehl nicht erfolgreich ist oder ein Fehler auftritt, finden Sie Informationen [Problembehandlung bei Ihrem Amazon MSK-Cluster](troubleshooting.md) zur Problembehandlung unter. 1. **(Optional) Löschen Sie die Umgebungsvariablen, die Sie in diesem Tutorial verwendet haben.** Wenn Sie Ihre Umgebungsvariablen für die nächsten Schritte in diesem Tutorial behalten möchten, überspringen Sie diesen Schritt. Andernfalls können Sie diese Variablen aufheben, wie im folgenden Beispiel gezeigt. ``` unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS ``` **Nächster Schritt** [Schritt 5: Produzieren und Verbrauchen von Daten](produce-consume.md) # Schritt 5: Produzieren und Verbrauchen von Daten In diesem Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) produzieren und konsumieren Sie Daten. **Erstellen und Verbrauchen von Nachrichten**Nachrichten produzieren und konsumieren 1. Führen Sie den folgenden Befehl aus, um einen Konsolenproduzenten zu starten. ``` $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic ``` 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 **Enter (Eingabetaste)** 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. Da es sich um eine neue Sitzung handelt, legen Sie die Umgebungsvariablen `KAFKA_ROOT` und die `BOOTSTRAP_SERVER` Umgebungsvariablen erneut fest. Hinweise zum Einstellen dieser Umgebungsvariablen finden Sie unter[Ein Thema auf dem Client-Computer erstellen](create-topic.md#create-topic-client-machine). 1. Führen Sie den folgenden Befehl mit Ihrer zweiten Verbindungszeichenfolge zum Client-Computer aus, um einen Console-Consumer zu erstellen. ``` $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning ``` Sie sollten nun die Meldungen sehen, die Sie zuvor eingegeben haben, als Sie den Befehl Console Producer verwendet haben. 1. Geben Sie weitere Nachrichten in das Producer-Fenster ein und beobachten Sie, wie sie im Consumer-Fenster angezeigt werden. **Nächster Schritt** [Schritt 6: Amazon CloudWatch zum Anzeigen von Amazon MSK-Metriken verwenden](view-metrics.md) # Schritt 6: Amazon CloudWatch zum Anzeigen von Amazon MSK-Metriken verwenden In diesem Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) sehen Sie sich die Amazon MSK-Metriken in Amazon an. CloudWatch **Um Amazon MSK-Metriken anzuzeigen in CloudWatch**Metriken anzeigen in CloudWatch 1. Öffnen Sie die CloudWatch Konsole unter [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/). 1. Wählen Sie im Navigationsbereich **Metriken** aus. 1. Wählen Sie die Registerkarte **All Metrics (Alle Metriken)** und dann **AWS/Kafka**. 1. Um Metriken auf Broker-Ebene anzuzeigen, wählen Sie **Broker ID, Cluster Name (Broker-ID, Cluster-Name)**. Wählen Sie für Metriken auf Cluster-Ebene **Cluster Name (Clustername)**. 1. (Optional) Wählen Sie im Grafikbereich eine Statistik und einen Zeitraum aus, und erstellen Sie dann mit diesen Einstellungen einen CloudWatch Alarm. **Nächster Schritt** [Schritt 7: Löschen Sie die für dieses Tutorial erstellten AWS Ressourcen](delete-cluster.md) # Schritt 7: Löschen Sie die für dieses Tutorial erstellten AWS Ressourcen Im letzten Schritt von [Erste Schritte mit Amazon MSK](getting-started.md) löschen Sie den MSK-Cluster und den Client-Computer, die Sie für dieses Tutorial erstellt haben. **Um die Ressourcen mit dem zu löschen AWS-Managementkonsole**Löschen Sie Ressourcen mit dem AWS-Managementkonsole 1. Öffnen Sie die Amazon-MSK-Konsole unter [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Wählen Sie den Namen Ihres Clusters aus. Zum Beispiel **MSKTutorialCluster**. 1. Wählen Sie **Actions (Aktionen)** und dann **Delete (Löschen)**. 1. Öffnen Sie die Amazon-EC2-Konsole unter [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Wählen Sie die Instance aus, die Sie für Ihren Client-Computer erstellt haben, z. B. **MSKTutorialClient**. 1. Wählen Sie **Instance-Status** und dann **Instance beenden**. **So löschen Sie die IAM-Richtlinie und -Rolle**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.