Erstellen Sie ein Apache Kafka-Thema - Amazon Managed Streaming für Apache Kafka
Richten Sie Ihre Umgebung für die Erstellung von Themen einEin Thema erstellen und Daten dazu schreiben

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.

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.

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=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • Führen Sie Kafka-Befehle mit dem vollständigen Java-Befehl mit explicit ausclasspath, wie im folgenden Beispiel gezeigt.

      java -cp "<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/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

  2. Führen Sie den folgenden Befehl aus, um ein Thema mit dem Namen msk-serverless-tutorial zu erstellen.

    <path-to-your-kafka-installation>/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