Schritt 4: Erstellen Sie ein Thema im MSK Amazon-Cluster - Amazon Managed Streaming für Apache Kafka

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.

Schritt 4: Erstellen Sie ein Thema im MSK Amazon-Cluster

In diesem Schritt von Erste Schritte mit Amazon MSK installieren Sie Apache Kafka-Clientbibliotheken und -Tools auf dem Client-Computer und erstellen anschließend ein Thema.

Warnung

Die in diesem Tutorial verwendeten Versionsnummern von Apache Kafka sind nur Beispiele. Wir empfehlen, dass Sie dieselbe Version des Clients wie Ihre MSK Cluster-Version verwenden. In einer älteren Client-Version fehlen möglicherweise bestimmte Funktionen und kritische Bugfixes.

Um die Version Ihres MSK Clusters zu finden

  1. Gehen Sie zu https://eu-west-2.console.aws.amazon.com/msk/

  2. Wählen Sie den MSK-Cluster.

  3. Notieren Sie sich die Version von Apache Kafka, die auf dem Cluster verwendet wird.

  4. Ersetzen Sie Instanzen von MSK Amazon-Versionsnummern in diesem Tutorial durch die Version, die Sie in Schritt 3 erhalten haben.

Erstellen eines Themas auf dem Client-Computer

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

  2. Wählen Sie im Navigationsbereich Instances aus. Aktivieren Sie dann das Kontrollkästchen neben dem Namen des Client-Computers, den Sie in Schritt 3: Einen Client-Computer erstellen erstellt haben.

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

  4. Installieren Sie Java auf dem Client-Computer, indem Sie den folgenden Befehl ausführen:

    sudo yum -y install java-11

  5. Führen Sie den folgenden Befehl aus, um Apache Kafka herunterzuladen. 

    wget https://archive.apache.org/dist/kafka/{YOUR MSK VERSION}/kafka_2.13-{YOUR MSK VERSION}.tgz
    Anmerkung

    Wenn Sie eine andere als die in diesem Befehl verwendete Spiegelsite verwenden möchten, können Sie eine andere auf der Apache-Website auswählen.

  6. Führen Sie den folgenden Befehl in dem Verzeichnis aus, in das Sie die TAR Datei im vorherigen Schritt heruntergeladen haben.

    tar -xzf kafka_2.13-{YOUR MSK VERSION}.tgz

  7. Gehen Sie in das kafka_2.13-{YOUR MSK VERSION}/libs Verzeichnis und führen Sie dann den folgenden Befehl aus, um die MSK IAM JAR Amazon-Datei herunterzuladen. Amazon MSK IAM JAR ermöglicht es dem Client-Computer, auf den Cluster zuzugreifen.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v1.1.1/aws-msk-iam-auth-1.1.1-all.jar

  8. Wechseln Sie zum Verzeichnis kafka_2.13-{YOUR MSK VERSION}/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

  9. Öffnen Sie die MSK Amazon-Konsole unterhttps://console.aws.amazon.com/msk/.

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

  11. Wählen Sie Client-Informationen anzeigen.

  12. Kopieren Sie die Verbindungszeichenfolge für den privaten Endpunkt.

    Sie erhalten drei Endpunkte für jeden der Broker. Für den folgenden Schritt benötigen Sie nur einen Broker-Endpunkt.

  13. Führen Sie den folgenden Befehl aus und BootstrapServerString ersetzen Sie ihn durch einen der Broker-Endpunkte, die Sie im vorherigen Schritt abgerufen haben.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server BootstrapServerString --command-config client.properties --replication-factor 3 --partitions 1 --topic MSKTutorialTopic

    Wenn der Befehl erfolgreich ist, wird die folgende Meldung angezeigt: Created topic MSKTutorialTopic.

Nächster Schritt

Schritt 5: Produzieren und Verbrauchen von Daten