ApsaraMQ for Kafka:Se connecter à 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	Faites correspondre la région à celle de vos serveurs d'application pour 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	Ultra Disk convient aux charges de travail générales. Utilisez SSD pour un débit élevé ou de grands 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

Rassemblez 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 : Trouvez cette information dans la colonne Instance ID/name.

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

Pas de 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 bloc CIDR de sous-réseau tel que 192.168.0.0/24.

Étape 3 : Déployer l'instance

1. Dans la console ApsaraMQ for Kafka, recherchez l'instance à l'état 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 de l'étape 2.
   vSwitch ID	Sélectionnez le vSwitch de l'étape 2.
   Version	Sélectionnez 2.6.2 (recommandé) ou 2.2.0.
   Message retention period	Durée de conservation des messages. Par défaut : 72 heures.
   Maximum message size	Taille maximale par message. Par défaut : 1 Mo.
   Consumer offset retention period	Durée de conservation des offsets des consommateurs. 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 l'endpoint de l'instance

Une fois que l'instance est à 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 l'endpoint de l'instance.

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

   Exemple de format d'endpoint :

   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 l'endpoint et définissez-le comme valeur bootstrap.servers dans votre client Kafka.

Étape 5 : Configurer la liste d'autorisation de l'endpoint

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, recherchez l'endpoint 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 de l'endpoint.