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. # Commencez à utiliser Amazon MSK Ce didacticiel présente un exemple de la manière dont vous pouvez créer un cluster MSK, produire et consommer des données et surveiller l'état de votre cluster à l'aide de métriques. Cet exemple ne représente pas toutes les options que vous pouvez choisir lorsque vous créez un cluster MSK. Dans ce didacticiel, nous choisissons à plusieurs reprises les options par défaut par souci de simplicité. Cela ne signifie pas qu'il s'agit des seules options qui fonctionnent pour configurer un cluster MSK ou des instances clients. **Topics** + [Étape 1 : Création d'un cluster provisionné MSK](create-cluster.md) + [Étape 2 : créer un rôle IAM octroyant l'accès pour créer des rubriques sur le cluster Amazon MSK](create-client-iam-role.md) + [Étape 3 : Créer un ordinateur client](create-client-machine.md) + [Étape 4 : créer une rubrique dans le cluster Amazon MSK](create-topic.md) + [Étape 5 : Produire et consommer des données](produce-consume.md) + [Étape 6 : Utiliser Amazon CloudWatch pour consulter les métriques Amazon MSK](view-metrics.md) + [Étape 7 : Supprimer les AWS ressources créées pour ce didacticiel](delete-cluster.md) # Étape 1 : Création d'un cluster provisionné MSK Dans cette étape de prise [en main d'Amazon MSK](getting-started.md), vous créez un cluster Amazon MSK provisioned. Vous utilisez l'option de **création rapide** AWS Management Console pour créer ce cluster. **Pour créer un cluster Amazon MSK à l'aide du AWS Management Console**Créez un cluster à l'aide du AWS Management Console 1. Connectez-vous à la AWS Management Console console Amazon MSK et ouvrez-la [https://console.aws.amazon.com/msk/chez vous ? region=us-east-1\$1/home/](https://console.aws.amazon.com/msk/home?region=us-east-1#/home/). 1. Choisissez **Créer un cluster**. 1. Dans **Méthode de création**, laissez l'option **Création rapide** sélectionnée. L'option **Création rapide** vous permet de créer un cluster avec les paramètres par défaut. 1. Dans **Nom de cluster**, saisissez un nom descriptif pour votre cluster. Par exemple, **MSKTutorialCluster**. 1. Pour les **propriétés générales du cluster**, procédez comme suit : 1. Pour le **type de cluster**, choisissez **Provisioned.** 1. Choisissez une **version d'Apache Kafka** à exécuter sur les courtiers. Choisissez **Afficher la compatibilité des versions** pour voir un tableau de comparaison. 1. Pour le **type de courtier**, choisissez les courtiers Standard ou Express. 1. Choisissez une **taille de courtier**. 1. À partir du tableau situé sous **Tous les paramètres du cluster**, copiez les valeurs des paramètres suivants et enregistrez-les car vous en aurez besoin ultérieurement dans ce didacticiel : + VPC + Subnets + Groupes de sécurité associés au VPC 1. Choisissez **Créer un cluster**. 1. Vérifiez le **Statut** du cluster sur la page **Résumé du cluster**. Le statut passe de **Création** à **Actif** à mesure qu'Amazon MSK alloue le cluster. Lorsque le statut est **Actif**, vous pouvez vous connecter au cluster. Pour de plus amples informations sur le statut des clusters, consultez [Comprendre les états des clusters provisionnés par MSK](msk-cluster-states.md). **Étape suivante** [Étape 2 : créer un rôle IAM octroyant l'accès pour créer des rubriques sur le cluster Amazon MSK](create-client-iam-role.md) # Étape 2 : créer un rôle IAM octroyant l'accès pour créer des rubriques sur le cluster Amazon MSK Au cours de cette étape, vous effectuez deux tâches. La première tâche consiste à créer une politique IAM qui autorise l'accès à la création de rubriques sur le cluster et à l'envoi de données vers ces rubriques. La deuxième tâche consiste à créer un rôle IAM et à lui associer cette politique. À une étape ultérieure, vous créez un ordinateur client qui assume ce rôle et l'utilise pour créer une rubrique sur le cluster et pour envoyer des données à cette rubrique. **Pour créer une politique IAM permettant de créer des rubriques et d'y écrire**Créer une politique IAM 1. Ouvrez la console IAM à l’adresse [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. Dans le panneau de navigation, choisissez **Politiques**. 1. Choisissez **Create Policy** (Créer une politique). 1. Dans l'**éditeur de politiques**, choisissez **JSON**, puis remplacez le JSON dans la fenêtre de l'éditeur par le JSON suivant. Dans l'exemple suivant, remplacez ce qui suit : + *region*avec le code de l' Région AWS endroit où vous avez créé votre cluster. + Exemple d'identifiant de compte*123456789012*, avec votre Compte AWS identifiant. + *MSKTutorialCluster*et*MSKTutorialCluster*/*7d7131e1-25c5-4e9a-9ac5-ea85bee4da11-14*, avec le nom de votre cluster et son identifiant. ------ #### [ 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/*" ] } ] } ``` ------ Pour obtenir des instructions sur la façon de rédiger des politiques de sécurité, consultez[Contrôle d'accès IAM](iam-access-control.md). 1. Choisissez **Suivant**. 1. Sur la page **Examiner et créer**, procédez comme suit : 1. Pour **Nom de la politique**, entrez un nom descriptif, tel que**msk-tutorial-policy**. 1. Dans **Autorisations définies dans cette politique**, passez en revue et and/or modifiez les autorisations définies dans votre politique. 1. (Facultatif) Pour identifier, organiser ou rechercher la politique, choisissez **Ajouter une nouvelle balise pour ajouter** des balises sous forme de paires clé-valeur. Par exemple, ajoutez une balise à votre politique avec la paire clé-valeur et. **Environment** **Test** Pour plus d'informations sur l'utilisation des balises, consultez la section [Balises pour les Gestion des identités et des accès AWS ressources](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) dans le *guide de l'utilisateur IAM*. 1. Choisissez **Create Policy** (Créer une politique). **Pour créer un rôle IAM et lui attacher la politique** 1. Dans le volet de navigation, choisissez **Rôles**, puis sélectionnez **Créer un rôle**. 1. Sur la page **Select trusted entity** (Sélectionner une entité de confiance), procédez comme suit : 1. Pour **Trusted entity** (Entité de confiance), choisissez **Service AWS**. 1. Pour **Service ou cas d'utilisation**, choisissez **EC2.** 1. Sous **Cas d'utilisation**, choisissez **EC2**. 1. Choisissez **Suivant**. 1. Sur la page **Add permissions** (Ajouter des autorisations), procédez comme suit : 1. Dans le champ de recherche sous **Politiques d'autorisations**, entrez le nom de la politique que vous avez créée précédemment pour ce didacticiel. Ensuite, cochez la case située à gauche du nom de la politique. 1. (Facultatif) Définissez une [limite d'autorisations](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_boundaries.html). Il s’agit d’une fonctionnalité avancée disponible pour les fonctions de service, mais pas pour les rôles liés à un service. Pour plus d'informations sur la définition d'une limite d'autorisations, voir [Création de rôles et attachement de politiques (console)](https://docs.aws.amazon.com/IAM/latest/UserGuide/access_policies_job-functions_create-policies.html) dans le *guide de l'utilisateur IAM*. 1. Choisissez **Suivant**. 1. Sur la page **Name, review, and create** (Nommer, vérifier et créer), procédez comme suit : 1. Pour **Nom du rôle**, entrez un nom descriptif, tel que**msk-tutorial-role**. **Important** Lorsque vous nommez un rôle, notez ce qui suit : Les noms de rôles doivent être uniques au sein du Compte AWS vôtre et ne peuvent pas être rendus uniques au cas par cas. Par exemple, ne créez pas deux rôles nommés **PRODROLE** et **prodrole**. Lorsqu’un nom de rôle est utilisé dans une politique ou dans le cadre d’un ARN, le nom de rôle est sensible à la casse. Cependant, lorsqu’un nom de rôle apparaît aux clients dans la console, par exemple lors de la procédure d’ouverture de session, le nom de rôle est insensible à la casse. Vous ne pouvez pas modifier le nom du rôle après sa création, car d’autres entités pourraient y faire référence. 1. (Facultatif) Pour **Description**, saisissez la description du rôle. 1. (Facultatif) Pour modifier les cas d'utilisation et les autorisations du rôle, à l'**étape 1 : Sélectionnez les entités de confiance** ou à l'**étape 2 : Ajouter des sections d'autorisations**, choisissez **Modifier**. 1. (Facultatif) Pour identifier, organiser ou rechercher le rôle, choisissez **Ajouter une nouvelle balise pour ajouter** des balises sous forme de paires clé-valeur. Par exemple, ajoutez une balise à votre rôle avec la paire clé-valeur et. **ProductManager** **John** Pour plus d'informations sur l'utilisation des balises, consultez la section [Balises pour les Gestion des identités et des accès AWS ressources](https://docs.aws.amazon.com/IAM/latest/UserGuide/id_tags.html) dans le *guide de l'utilisateur IAM*. 1. Passez en revue les informations du rôle, puis choisissez **Create role** (Créer un rôle). **Étape suivante** [Étape 3 : Créer un ordinateur client](create-client-machine.md) # Étape 3 : Créer un ordinateur client Dans cette étape de [Get Started Using Amazon MSK](getting-started.md), vous créez une machine cliente. Vous utilisez cet ordinateur client pour créer une rubrique qui produit et consomme des données. Pour des raisons de simplicité, vous allez créer cet ordinateur client dans le VPC associé au cluster MSK afin que le client puisse facilement se connecter au cluster. **Pour créer un ordinateur client**Création d'une machine cliente 1. Ouvrez la console Amazon EC2 à l’adresse [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Sur le tableau de bord de la console Amazon EC2, sélectionnez **Launch instance (Lancer une instance)**. 1. Sous **Nom et balises**, dans **Nom**, entrez un nom descriptif pour votre machine cliente afin de pouvoir facilement en assurer le suivi. Par exemple, **MSKTutorialClient**. 1. Sous **Images d'application et de système d'exploitation (Amazon Machine Image)**, pour **Amazon Machine Image (AMI)**, choisissez **Amazon Linux 2 AMI (HVM) - Kernel 5.10, type de volume SSD**. 1. Pour le **type d'instance**, conservez la sélection par défaut de **t2.micro.** 1. Sous **Paire de clés (connexion)**, choisissez une paire de clés existante ou créez-en une nouvelle. Si vous n'avez pas besoin d'une paire de clés pour vous connecter à votre instance, vous pouvez choisir **Proceed without a key pair (ce n'est pas recommandé)**. Pour créer une paire de clés, procédez comme suit : 1. Choisissez **Créer une nouvelle paire de clés**. 1. Pour **Key pair name** (Nom de la paire de clés), saisissez **MSKKeyPair**. 1. Pour le **type de paire de clés** et **le format de fichier de clé privée**, conservez les sélections par défaut. 1. Choisissez **Créer une paire de clés**. Vous pouvez utiliser également une paire de clés existante. 1. Faites défiler la page vers le bas et développez la section **Détails avancés**, puis procédez comme suit : 1. Pour le **profil d'instance IAM**, choisissez le rôle IAM que vous souhaitez que la machine cliente assume. Si vous n'avez pas de rôle IAM, procédez comme suit : 1. Choisissez **Créer un nouveau profil IAM**. 1. Procédez comme indiqué dans [Étape 2 : Création d'un rôle IAM](create-client-iam-role.md). 1. Choisissez **Lancer l'instance**. 1. Choisissez **View Instances (Afficher les instances)**. Ensuite, dans la colonne **Groupes de sécurité**, choisissez le groupe de sécurité associé à votre nouvelle instance. Copiez l'ID du groupe de sécurité et enregistrez-le pour plus tard. 1. Ouvrez la console Amazon VPC à l’adresse [https://console.aws.amazon.com/vpc/](https://console.aws.amazon.com/vpc/). 1. Dans le panneau de navigation, choisissez **Groupes de sécurité**. Trouvez le groupe de sécurité dont vous avez enregistré l'identifiant dans [Étape 1 : Création d'un cluster provisionné MSK](create-cluster.md). 1. Sous l'onglet **Règles entrantes**, choisissez **Modifier les règles entrantes**. 1. Choisissez **Ajouter une règle**. 1. Dans la nouvelle règle, choisissez **Tout le trafic** dans la colonne **Type** . Dans le deuxième champ de la colonne **Source**, sélectionnez le groupe de sécurité de votre ordinateur client. Il s'agit du groupe dont vous avez enregistré le nom après avoir lancé l'instance d'ordinateur client. 1. Sélectionnez **Enregistrer les règles**. Le groupe de sécurité du cluster peut désormais accepter le trafic provenant du groupe de sécurité de l'ordinateur client. **Étape suivante** [Étape 4 : créer une rubrique dans le cluster Amazon MSK](create-topic.md) # Étape 4 : créer une rubrique dans le cluster Amazon MSK Dans cette étape de [Getting Started Using Amazon MSK](getting-started.md), vous pouvez créer une rubrique en utilisant l'une des deux approches suivantes : en utilisant des AWS outils natifs avec l' CreateTopic API ou en utilisant les AdminClient outils Apache Kafka sur une machine cliente. **Avertissement** Lorsque vous utilisez AWS des outils avec l' CreateTopic API, vérifiez que votre cluster répond aux exigences. Pour plus de détails, consultez [la rubrique Conditions d'utilisation APIs](https://docs.aws.amazon.com/msk/latest/developerguide/msk-topic-operations-information.html#topic-operations-requirements). **Avertissement** Lorsque vous utilisez AdminClient cette approche, 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 votre version de cluster MSK. Certaines fonctionnalités et corrections de bogues critiques peuvent être absentes d'une ancienne version du client. **Topics** + [Création d'un sujet à l'aide d' AWS outils](#create-topic-aws-tools) + [Déterminer la version de votre cluster MSK](#find-msk-cluster-version) + [Création d'un sujet sur la machine cliente](#create-topic-client-machine) ## Création d'un sujet à l'aide d' AWS outils Vous pouvez créer des sujets dans votre cluster MSK à l'aide AWS d'outils tels que la AWS CLI ou la console AWS de gestion. AWS SDKs Cette approche permet de gérer les sujets de manière rationalisée sans avoir besoin d'un accès direct aux outils clients de Kafka. Pour obtenir des informations détaillées sur la création de rubriques à l'aide AWS des outils, consultez le [guide du développeur d'CreateTopic API](https://docs.aws.amazon.com/msk/latest/developerguide/msk-create-topic.html). ## Déterminer la version de votre cluster MSK 1. Ouvrez la console Amazon MSK à l'adresse [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Dans la barre de navigation, choisissez la région dans laquelle vous avez créé le cluster MSK. 1. Choisissez le cluster MSK. 1. Notez la version d'Apache Kafka utilisée sur le cluster. 1. Remplacez les instances des numéros de version d'Amazon MSK dans ce didacticiel par la version obtenue à l'étape 3. ## Création d'un sujet sur la machine cliente 1. **Connect à votre machine cliente.** 1. Ouvrez la console Amazon EC2 à l’adresse [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Dans le panneau de navigation, choisissez **Instances**. Cochez ensuite la case à côté du nom de la machine cliente dans laquelle vous l'avez créée[Étape 3 : Créer un ordinateur client](create-client-machine.md). 1. Choisissez **Actions**, puis **Modifier**. Suivez les instructions dans la console pour vous connecter à votre ordinateur client. 1. **Installez Java et configurez la variable d'environnement de version de Kafka.** 1. Installez Java sur la machine cliente en exécutant la commande suivante. ``` sudo yum -y install java-11 ``` 1. Stockez la [version Kafka](#find-msk-cluster-version) de votre cluster MSK dans la variable d'environnement`KAFKA_VERSION`, comme indiqué dans la commande suivante. Vous aurez besoin de ces informations tout au long de la configuration. ``` export KAFKA_VERSION={KAFKA VERSION} ``` Par exemple, si vous utilisez la version 3.6.0, utilisez la commande suivante. ``` export KAFKA_VERSION=3.6.0 ``` 1. **Téléchargez et décompressez Apache Kafka.** 1. Exécutez la commande suivante pour télécharger Apache Kafka. ``` wget https://archive.apache.org/dist/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` **Note** La liste suivante présente des informations de téléchargement alternatives de Kafka que vous pouvez utiliser en cas de problème. Si vous rencontrez des problèmes de connectivité ou si vous souhaitez utiliser un site miroir, essayez d'utiliser le sélecteur de miroir Apache, comme indiqué dans la commande suivante. ``` wget https://www.apache.org/dyn/closer.cgi?path=/kafka/$KAFKA_VERSION/kafka_2.13-$KAFKA_VERSION.tgz ``` Téléchargez une version appropriée directement depuis le [site Web d'Apache Kafka](https://kafka.apache.org/downloads). 1. Exécutez la commande suivante dans le répertoire où vous avez téléchargé le fichier TAR à l'étape précédente. ``` tar -xzf kafka_2.13-$KAFKA_VERSION.tgz ``` 1. Enregistrez le chemin complet du répertoire nouvellement créé dans la variable d'`KAFKA_ROOT`environnement. ``` export KAFKA_ROOT=$(pwd)/kafka_2.13-$KAFKA_VERSION ``` 1. **Configurez l'authentification pour votre cluster MSK.** 1. [Trouvez la dernière version](https://github.com/aws/aws-msk-iam-auth/releases/latest) de la bibliothèque cliente Amazon MSK IAM. Cette bibliothèque permet à votre machine cliente d'accéder au cluster MSK à l'aide de l'authentification IAM. 1. À l'aide des commandes suivantes, accédez au `$KAFKA_ROOT/libs` répertoire et téléchargez le fichier JAR Amazon MSK IAM associé que vous avez trouvé à l'étape précédente. Assurez-vous de le remplacer par le numéro *\$1LATEST VERSION\$1* de version réel que vous êtes en train de télécharger. ``` cd $KAFKA_ROOT/libs ``` ``` wget https://github.com/aws/aws-msk-iam-auth/releases/latest/download/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` **Note** Avant d'exécuter des commandes Kafka qui interagissent avec votre cluster MSK, vous devrez peut-être ajouter le fichier Amazon MSK IAM JAR à votre chemin de classe Java. Définissez la variable d'`CLASSPATH`environnement, comme indiqué dans l'exemple suivant. ``` export CLASSPATH=$KAFKA_ROOT/libs/aws-msk-iam-auth-{LATEST VERSION}-all.jar ``` Cela définit la valeur `CLASSPATH` pour l'ensemble de votre session, rendant le JAR disponible pour toutes les commandes Kafka suivantes. 1. Accédez au `$KAFKA_ROOT/config` répertoire pour créer le fichier de configuration du client. ``` cd $KAFKA_ROOT/config ``` 1. Copiez les paramètres de propriété suivants et collez-les dans un nouveau fichier. Enregistrez le fichier sous le nom **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. **(Facultatif) Ajustez la taille du tas Java pour les outils Kafka.** Si vous rencontrez des problèmes liés à la mémoire ou si vous travaillez sur un grand nombre de sujets ou de partitions, vous pouvez ajuster la taille du segment de mémoire Java. Pour ce faire, définissez la variable d'`KAFKA_HEAP_OPTS`environnement avant d'exécuter les commandes Kafka. L'exemple suivant définit à la fois la taille maximale et la taille initiale du tas à 512 mégaoctets. Ajustez ces valeurs en fonction de vos besoins spécifiques et des ressources système disponibles. ``` export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M" ``` 1. **Obtenez les informations de connexion à votre cluster.** 1. Ouvrez la console Amazon MSK à l'adresse [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. 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. 1. Choisissez **Afficher les informations sur le client**. 1. Copiez la chaîne de connexion pour le point de terminaison privé. Vous obtiendrez trois points de terminaison pour chacun des courtiers. Stockez l'une de ces chaînes de connexion dans la variable d'environnement`BOOTSTRAP_SERVER`, comme indiqué dans la commande suivante. Remplacez ** par la valeur réelle de la chaîne de connexion. ``` export BOOTSTRAP_SERVER= ``` 1. **Exécutez la commande suivante pour créer le sujet.** ``` $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 ``` Si vous obtenez un `NoSuchFileException` pour le `client.properties` fichier, assurez-vous que ce fichier existe dans le répertoire de travail actuel du répertoire bin de Kafka. **Note** Si vous préférez ne pas définir la variable d'`CLASSPATH`environnement pour l'ensemble de votre session, vous pouvez également préfixer chaque commande Kafka par la `CLASSPATH` variable. Cette approche applique le chemin de classe uniquement à cette commande spécifique. ``` 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. **(Facultatif) Vérifiez que le sujet a été créé correctement.** 1. Si la commande aboutit, le message suivant devrait s'afficher : `Created topic MSKTutorialTopic.` 1. Répertoriez tous les sujets pour confirmer l'existence de votre sujet. ``` $KAFKA_ROOT/bin/kafka-topics.sh --list --bootstrap-server $BOOTSTRAP_SERVER --command-config $KAFKA_ROOT/config/client.properties ``` Si la commande échoue ou si vous rencontrez une erreur, consultez [Résoudre les problèmes liés à votre cluster Amazon MSK](troubleshooting.md) les informations de dépannage. 1. **(Facultatif) Supprimez les variables d'environnement que vous avez utilisées dans ce didacticiel.** Si vous souhaitez conserver vos variables d'environnement pour les prochaines étapes de ce didacticiel, ignorez cette étape. Dans le cas contraire, vous pouvez désactiver ces variables, comme indiqué dans l'exemple suivant. ``` unset KAFKA_VERSION KAFKA_ROOT BOOTSTRAP_SERVER CLASSPATH KAFKA_HEAP_OPTS ``` **Étape suivante** [Étape 5 : Produire et consommer des données](produce-consume.md) # Étape 5 : Produire et consommer des données Dans cette étape de [Get Started Using Amazon MSK](getting-started.md), vous produisez et consommez des données. **Pour produire et consommer des messages**Produire et consommer des messages 1. Exécutez la commande suivante pour démarrer un producteur de console. ``` $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic ``` 1. Saisissez le message souhaité, puis appuyez sur **Entrée**. Répétez cette étape deux ou trois fois. Chaque fois que vous entrez une ligne et appuyez sur **Entrée**, cette ligne est envoyée à votre cluster Apache Kafka sous forme de message distinct. 1. Gardez la connexion à l'ordinateur client ouverte, puis ouvrez une deuxième connexion séparée à cet ordinateur dans une nouvelle fenêtre. Comme il s'agit d'une nouvelle session, définissez à nouveau les variables d'`BOOTSTRAP_SERVER`environnement `KAFKA_ROOT` et. Pour plus d'informations sur la façon de définir ces variables d'environnement, consultez[Création d'un sujet sur la machine cliente](create-topic.md#create-topic-client-machine). 1. Exécutez la commande suivante avec votre deuxième chaîne de connexion à la machine cliente pour créer un consommateur de console. ``` $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning ``` Vous devriez commencer à voir les messages que vous avez entrés plus tôt lorsque vous avez utilisé la commande console producer. 1. Entrez d'autres messages dans la fenêtre du producteur et regardez-les apparaître dans la fenêtre du consommateur. **Étape suivante** [Étape 6 : Utiliser Amazon CloudWatch pour consulter les métriques Amazon MSK](view-metrics.md) # Étape 6 : Utiliser Amazon CloudWatch pour consulter les métriques Amazon MSK Dans cette étape de [Getting Started Using Amazon MSK](getting-started.md), vous examinez les métriques Amazon MSK sur Amazon. CloudWatch **Pour consulter les statistiques Amazon MSK dans CloudWatch**Afficher les métriques dans CloudWatch 1. Ouvrez la CloudWatch console à l'adresse [https://console.aws.amazon.com/cloudwatch/](https://console.aws.amazon.com/cloudwatch/). 1. Dans le panneau de navigation, sélectionnez ‎**Métriques**. 1. Choisissez l'onglet **Toutes les métriques**, puis **AWS/Kafka**. 1. Pour afficher les métriques au niveau du broker, choisissez **ID du broker, Nom du cluster**. Pour les métriques au niveau du cluster, choisissez **Nom du cluster**. 1. (Facultatif) Dans le volet graphique, sélectionnez une statistique et une période, puis créez une CloudWatch alarme à l'aide de ces paramètres. **Étape suivante** [Étape 7 : Supprimer les AWS ressources créées pour ce didacticiel](delete-cluster.md) # Étape 7 : Supprimer les AWS ressources créées pour ce didacticiel À l'étape finale de [Mise en route avec Amazon MSK](getting-started.md), vous supprimez le cluster MSK et l'ordinateur client que vous avez créés pour ce didacticiel. **Pour supprimer les ressources à l'aide du AWS Management Console**Supprimez des ressources à l'aide du AWS Management Console 1. Ouvrez la console Amazon MSK à l'adresse [https://console.aws.amazon.com/msk/](https://console.aws.amazon.com/msk/). 1. Choisissez le nom de votre cluster. Par exemple, **MSKTutorialCluster**. 1. Choisissez **Actions**, puis **Delete (Supprimer)**. 1. Ouvrez la console Amazon EC2 à l’adresse [https://console.aws.amazon.com/ec2/](https://console.aws.amazon.com/ec2/). 1. Choisissez l'instance que vous avez créée pour votre ordinateur client, par exemple, **MSKTutorialClient**. 1. Choisissez **État de l'instance**, puis **Résilier l'instance**. **Pour supprimer la politique et le rôle IAM**Supprimer la politique et le rôle IAM 1. Ouvrez la console IAM à l’adresse [https://console.aws.amazon.com/iam/](https://console.aws.amazon.com/iam/). 1. Dans le panneau de navigation, choisissez **Rôles**. 1. Dans la zone de recherche, saisissez le nom du rôle IAM que vous avez créé pour ce didacticiel. 1. Choisissez le rôle. Ensuite, choisissez **Supprimer le rôle** et confirmez la suppression. 1. Dans le panneau de navigation, choisissez **Politiques**. 1. Dans la zone de recherche, saisissez le nom de la politique que vous avez créée pour ce didacticiel. 1. Choisissez la politique pour ouvrir sa page récapitulative. Sur la page **Récapitulatif** de la politique, choisissez **Supprimer la politique**. 1. Sélectionnez **Supprimer**.