Étape 4 : créer un sujet dans le MSK cluster Amazon - Amazon Managed Streaming for Apache Kafka

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.

Étape 4 : créer un sujet dans le MSK cluster Amazon

Dans cette étape de Getting Started Using Amazon MSK, vous installez les bibliothèques clientes et les outils Apache Kafka sur la machine cliente, puis vous créez une rubrique.

Avertissement

Les numéros de version d'Apache Kafka utilisés dans ce didacticiel ne sont que des exemples. Nous vous recommandons d'utiliser la même version du client que celle de votre MSK cluster. Certaines fonctionnalités et correctifs de bogues critiques peuvent être absents d'une ancienne version du client.

Pour trouver la version de votre MSK cluster

  1. Allez à https://eu-west-2.console.aws.amazon.com/msk/

  2. Sélectionnez le cluster MSK.

  3. Notez la version d'Apache Kafka utilisée sur le cluster.

  4. Remplacez les instances des numéros de MSK version d'Amazon dans ce didacticiel par la version obtenue à l'étape 3.

Pour créer une rubrique sur l'ordinateur client

  1. Ouvrez la EC2 console Amazon à l'adresse https://console.aws.amazon.com/ec2/.

  2. Dans le panneau de navigation, choisissez Instances. Ensuite, cochez la case en regard du nom de l'ordinateur client que vous avez créé dans Étape 3 : Créer un ordinateur client.

  3. Choisissez Actions, puis Modifier. Suivez les instructions dans la console pour vous connecter à votre ordinateur client.

  4. Installez Java sur l'ordinateur client en exécutant la commande suivante :

    sudo yum -y install java-11

  5. Exécutez la commande suivante pour télécharger Apache Kafka. 

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

    Si vous souhaitez utiliser un site miroir autre que celui utilisé dans cette commande, vous pouvez en choisir un autre sur le site web Apache.

  6. Exécutez la commande suivante dans le répertoire où vous avez téléchargé le TAR fichier à l'étape précédente.

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

  7. Accédez au kafka_2.13-{YOUR MSK VERSION}/libs répertoire, puis exécutez la commande suivante pour télécharger le MSK IAM JAR fichier Amazon. Amazon MSK IAM JAR permet à la machine cliente d'accéder au cluster.

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

  8. Accédez au répertoire kafka_2.13-{YOUR MSK VERSION}/bin. Copiez les paramètres de propriété suivants et collez-les dans un nouveau fichier. Nommez le fichier client.properties et enregistrez-le.

    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. Ouvrez la MSK console Amazon à l'adressehttps://console.aws.amazon.com/msk/.

  10. Attendez que le statut de votre cluster devienne Actif. Cela peut prendre plusieurs minutes. Lorsque le statut devient Actif, choisissez le nom du cluster. Cela vous amène à une page contenant le récapitulatif du cluster.

  11. Choisissez Afficher les informations sur le client.

  12. Copiez la chaîne de connexion pour le point de terminaison privé.

    Vous obtiendrez trois points de terminaison pour chacun des agents. Vous n'avez besoin que d'un seul point de terminaison d'agent pour l'étape suivante.

  13. Exécutez la commande suivante, en la BootstrapServerString remplaçant par l'un des points de terminaison du broker que vous avez obtenus à l'étape précédente.

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

    Si la commande réussit, le message suivant s'affiche : Created topic MSKTutorialTopic.

Étape suivante

Étape 5 : Produire et consommer des données