Étape 3 : Créer un ordinateur client et une rubrique Apache Kafka

Dans cette étape, vous créez une instance Amazon EC2 à utiliser comme instance de client Apache Kafka. Vous utilisez ensuite cette instance pour créer une rubrique sur le cluster.

Pour créer un ordinateur client

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

2. Sélectionnez Lancer des instances.

3. Saisissez un Nom pour votre ordinateur client, tel que mkc-tutorial-client.

4. Laissez Amazon Linux 2 AMI (HVM) - Kernel 5.10, type de volume SSD sélectionné pour le type Amazon Machine Image (AMI).

5. Choisissez le type d'instance t2.xlarge.

6. Sous Paire de clés (connexion), choisissez Créer une nouvelle paire de clés. Saisissez mkc-tutorial-key-pair dans Nom de la paire de clés, puis choisissez Télécharger la paire de clés. Vous pouvez utiliser également une paire de clés existante.

7. Choisissez Lancer l'instance.

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

Pour autoriser le client nouvellement créé à envoyer des données au cluster

1. Ouvrez la console Amazon VPC à l’adresse https://console.aws.amazon.com/vpc/.

2. Dans le volet de gauche, sélectionnez Groupes de sécurité sous l'onglet SÉCURITÉ. Dans la colonne ID du groupe de sécurité), recherchez le groupe de sécurité du cluster. Vous avez enregistré l'ID de ce groupe de sécurité lorsque vous avez créé le cluster dans Étape 1 : Configurer les ressources requises. Choisissez ce groupe de sécurité en cochant la case située à gauche de sa ligne. Assurez-vous qu'aucun autre groupe de sécurité n'est sélectionné simultanément.

3. Dans la moitié inférieure de l'écran, choisissez l'onglet Règles entrantes.

4. Choisissez Modifier les règles entrantes.

5. Dans le coin inférieur gauche de l'écran, choisissez Ajouter une règle.

6. Dans la nouvelle règle, choisissez Tout le trafic dans la colonne Type . Dans le champ à droite de la colonne Source, entrez l'ID du groupe de sécurité de l'ordinateur client. Il s'agit de l'ID du groupe de sécurité que vous avez enregistré après avoir créé l'ordinateur client.

7. Sélectionnez Enregistrer les règles. Votre cluster MSK accepte désormais tout le trafic provenant du client que vous avez créé dans la procédure précédente.

Pour créer une rubrique

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

2. Dans le tableau des instances, sélectionnez mkc-tutorial-client.

3. En haut de l'écran, choisissez Connexion, puis suivez les instructions pour vous connecter à l'instance.

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

   sudo yum install java-1.8.0

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

   wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.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 fichier TAR à l'étape précédente.

   tar -xzf kafka_2.12-2.2.1.tgz

7. Accédez au répertoire kafka_2.12-2.2.1.

8. Ouvrez la console Amazon MSK à l'adresse https://console.aws.amazon.com/msk/home?region=us-east-1#/home/.

9. Dans le volet de gauche, choisissez Clusters, puis choisissez le nommkc-tutorial-cluster.

10. Choisissez Afficher les informations sur le client.

11. Copiez la chaîne de connexion en texte brut.

12. Sélectionnez Exécuté.

13. Exécutez la commande suivante sur l'instance cliente (mkc-tutorial-client), en la bootstrapServerStringremplaçant par la valeur que vous avez enregistrée lorsque vous avez consulté les informations client du cluster.

    <path-to-your-kafka-installation>/bin/kafka-topics.sh --create --bootstrap-server bootstrapServerString --replication-factor 2 --partitions 1 --topic mkc-tutorial-topic

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

Étape suivante

Étape 4 : Créer un connecteur