Création d'un sujet Apache Kafka - Amazon Managed Streaming for Apache Kafka
Configuration de votre environnement pour la création de sujetsCréer un sujet et y écrire des données

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Création d'un sujet Apache Kafka

Dans cette étape, vous utilisez l'ordinateur client créé précédemment pour créer une rubrique sur le cluster sans serveur.

Configuration de votre environnement pour la création de sujets

  • Avant de créer un sujet, assurez-vous d'avoir téléchargé le fichier JAR AWS MSK IAM dans le répertoire de votre installation Kafka. libs/ Si vous ne l'avez pas encore fait, exécutez la commande suivante dans le libs/ répertoire de votre Kafka.

    wget https://github.com/aws/aws-msk-iam-auth/releases/download/v2.3.0/aws-msk-iam-auth-2.3.0-all.jar

    Ce fichier JAR est requis pour l'authentification IAM avec votre cluster MSK Serverless.

  • Lorsque vous exécutez des commandes Kafka, vous devrez peut-être vous assurer qu'elles classpath incluent le fichier JAR AWS MSK IAM. Pour ce faire, optez pour l'une des solutions suivantes :

    • Définissez la variable d'CLASSPATHenvironnement pour inclure vos bibliothèques Kafka, comme indiqué dans l'exemple suivant.

      export CLASSPATH=<path-to-your-kafka-installation>/libs/*:<path-to-your-kafka-installation>/libs/aws-msk-iam-auth-2.3.0-all.jar

    • Exécutez les commandes Kafka en utilisant la commande Java complète avec explicitclasspath, comme indiqué dans l'exemple suivant.

      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

Créer un sujet et y écrire des données

  1. Dans la export commande suivante, remplacez my-endpoint par la chaîne bootstrap-server que vous avez enregistrée après avoir créé le cluster. Accédez ensuite au répertoire kafka_2.12-2.8.1/bin de l'ordinateur client et exécutez la commande export.

    export BS=my-endpoint

  2. Exécutez la commande suivante pour créer une rubrique appelée msk-serverless-tutorial.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --bootstrap-server $BS --command-config client.properties --create --topic msk-serverless-tutorial --partitions 6

Étape suivante

Produire et consommer des données dans MSK Serverless