ApsaraMQ for Kafka:Connexion à ApsaraMQ for Kafka via un VPC

Prérequis

• Un VPC et un vSwitch existent dans la région cible. Vous pouvez les créer lors du déploiement si nécessaire.

Étape 1 : Créer une instance

1. Connectez-vous à la console ApsaraMQ for Kafka.

2. Dans la section Quick Start située à droite de la page, cliquez sur Create Instance.

3. Dans le panneau qui s’affiche, sélectionnez une Instance Series et un billing model :

   Billing model	Use cases
   Pay-as-you-go	Pour le développement, les tests ou les charges de travail dont le trafic fluctue.
   Subscription	Pour les environnements de production avec une utilisation et des coûts prévisibles.
   Serverless	Facturation basée sur l’utilisation réelle avec mise à l’échelle élastique automatique.

   Cliquez sur OK.

4. Sur la page d’achat, configurez les paramètres de l’instance :

   Parameter	Description
   Instance type	L’option Standard (High-write) convient à la plupart des cas d’utilisation.
   Region	Sélectionnez la même région que vos serveurs d’application afin de minimiser la latence.
   Instance type	Sélectionnez VPC instance.
   Traffic specification	Choisissez en fonction du débit estimé. Par exemple, alikafka.hw.2xlarge prend en charge 20 Mo/s en lecture/écriture.
   Disk type	L’Ultra Disk convient aux charges de travail générales. Utilisez un SSD pour un débit élevé ou d’importants arriérés de messages.
   Disk capacity	Basez la capacité sur votre période de rétention. Recommandation : 300 à 900 Go.

5. Cliquez sur Buy Now et effectuez le paiement.

Après l’achat, la liste des instances affiche l’instance avec l’état Not Deployed.

Étape 2 : Obtenir les informations VPC

Recueillez les ID de VPC et de vSwitch nécessaires au déploiement.

1. Connectez-vous à la console Virtual Private Cloud.

2. Dans le volet de navigation de gauche, cliquez sur vSwitches.

3. Dans la barre de navigation supérieure, sélectionnez la région cible.

4. Sur la page vSwitches, notez les informations suivantes :

   • vSwitch ID : Retrouvez cette information dans la colonne Instance ID/name.

   • VPC ID : Retrouvez cette information dans la colonne Virtual private cloud.

Aucun VPC ? Créez-en un rapidement

1. Dans la console Virtual Private Cloud, cliquez sur Create VPC.

2. Saisissez un nom et définissez un bloc CIDR IPv4, par exemple 192.168.0.0/16.

3. Ajoutez un vSwitch lors de la création du VPC. Sélectionnez une zone de disponibilité et définissez un sous-réseau CIDR, tel que 192.168.0.0/24.

Étape 3 : Déployer l’instance

1. Dans la console ApsaraMQ for Kafka, repérez l’instance dont l’état est Not Deployed sur la page de la liste des instances.

2. Dans la colonne Actions, cliquez sur Deploy.

3. Dans le panneau Deploy Instance, configurez les paramètres suivants :

   Parameter	Description
   VPC ID	Sélectionnez le VPC identifié à l’étape 2.
   vSwitch ID	Sélectionnez le vSwitch identifié à l’étape 2.
   Version	Sélectionnez 2.6.2 (recommandé) ou 2.2.0.
   Message retention period	Durée de conservation des messages. Valeur par défaut : 72 heures.
   Maximum message size	Taille maximale par message. Valeur par défaut : 1 Mo.
   Consumer offset retention period	Durée de conservation des offsets des consommateurs. Valeur par défaut : 10 080 minutes (7 jours).
   Disk encryption	Activez cette option pour chiffrer les données au repos.

   Édition Professional uniquement :

   • Cross-zone deployment — Répartissez l’instance sur plusieurs zones de disponibilité pour la reprise après sinistre.

   • ACL feature — Activez le contrôle d’accès avec authentification SASL.

4. Cliquez sur OK.

Étape 4 : Obtenir le point de terminaison de l’instance

Une fois que l’instance atteint l’état Running :

1. Sur la page de la liste des instances, cliquez sur le nom de l’instance pour ouvrir les détails de l’instance.

2. Dans la section Endpoint information, consultez le point de terminaison de l’instance.

   Type	Network	Protocol	Use case
   Default endpoint	VPC	PLAINTEXT	Accès depuis le VPC

   Exemple de format de point de terminaison :

   alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com:9092,
   alikafka-pre-public-intl-sg-xxxxx-2-vpc.alikafka.aliyuncs.com:9092,
   alikafka-pre-public-intl-sg-xxxxx-3-vpc.alikafka.aliyuncs.com:9092

3. Copiez le point de terminaison et définissez-le comme valeur pour bootstrap.servers dans votre client Kafka.

Étape 5 : Configurer la liste d’autorisation du point de terminaison

Par défaut, seuls les clients situés dans le même vSwitch peuvent se connecter. Pour autoriser l’accès depuis d’autres sous-réseaux VPC, configurez une liste d’autorisation.

1. Dans Endpoint information, repérez le point de terminaison et cliquez sur Manage Whitelist dans la colonne Actions.

2. Sur la page Whitelist Management, cliquez sur Add Whitelist Group.

3. Configurez le groupe de liste d’autorisation :

   • Group name : Saisissez un nom, par exemple app-servers.

   • IP addresses in group : Saisissez les adresses IP ou les blocs CIDR à autoriser.

4. Cliquez sur OK.

Vérifier la connectivité réseau

Exécutez cette commande depuis un serveur de votre VPC :

telnet alikafka-pre-public-intl-sg-xxxxx-1-vpc.alikafka.aliyuncs.com 9092

Une connexion réussie confirme que le réseau est correctement configuré.

Étapes suivantes

Une fois l’instance déployée et opérationnelle :

1. Créer un topic pour organiser les messages.

2. Créer un groupe pour gérer la consommation des messages.

3. Connecter votre application à l’aide du point de terminaison.