Message Queue for Apache Kafka propose un service de migration vers le cloud entièrement géré et sans maintenance pour synchroniser les données entre des clusters auto-gérés ou des instances inter-clouds et les instances Message Queue for Apache Kafka. Une fois la migration terminée, les métadonnées (informations de configuration Topic et Group) et les données de messages du cluster source sont synchronisées vers l'instance cible. Les métadonnées de l'instance cible restent cohérentes avec celles du cluster source et sont mises à jour en continu.
Prérequis
Vous avez acheté et déployé une ApsaraMQ for Kafka instance qui répond aux exigences suivantes :
|
Élément |
Description |
|
Statut |
Running |
|
Version |
Dernière version mineure de 2.2.0 ou 2.6.2. |
Vous pouvez consulter le statut et la version de votre instance dans la section Enter Basic Information de la page Instances de la console Message Queue for Apache Kafka.
Limitations
La fonctionnalité cloud migration de ApsaraMQ for Kafka présente les limitations suivantes :
|
Élément |
Limite |
|
Quantité |
Vous pouvez créer un maximum de 20 tâches de migration par |
|
Type d'édition |
|
|
Version de l'instance source |
La version open source doit être 1.0.0 ou ultérieure. |
Facturation
Le composant de migration vers le cloud pour ApsaraMQ for Kafka sera facturé à partir du 1er août 2026. Pour plus d'informations, consultez CU Postpaid.
Exigences réseau
Si vous devez utiliser la fonctionnalité de migration vers le cloud pour synchroniser les données d'une instance auto-gérée sur Internet public vers ApsaraMQ for Kafka, ou synchroniser les données interrégions d'une instance ApsaraMQ for Kafka dans un VPC vers une instance ApsaraMQ for Kafka dans un autre VPC, vous devez activer l'accès Internet pour l'instance, puis synchroniser les données via Internet. Pour plus d'informations, consultez Activer l'accès Internet (facultatif).
Si vous devez utiliser la fonctionnalité cloud migration pour synchroniser les données d'une instance dans un VPC vers une ApsaraMQ for Kafka instance dans un autre VPC, les ApsaraMQ for Kafka et ApsaraMQ for Kafka region s prennent en charge la connexion automatique des VPC. Dans les autres region s, vous devez connecter manuellement les VPC. Pour plus d'informations, consultez Connecter des VPC entre régions.
Activer l'accès Internet (facultatif)
Pour utiliser la fonctionnalité cloud migration afin d'accéder à d'autres services Alibaba Cloud ou à des endpoints publics cross-region, vous devez activer l'internet access.
-
Créez une passerelle NAT pour le VPC 1 qui héberge l'instance Message Queue for Apache Kafka.
Pour plus d'informations, consultez Passerelle NAT Internet.
-
Associez une
elastic IP addressà lanat gateway.Pour plus d'informations, consultez Associer une EIP à une ressource cloud.
-
Créez une entrée SNAT pour le vSwitch utilisé par l'instance Message Queue for Apache Kafka dans le VPC 1.
Pour plus d'informations, consultez Créer et gérer des entrées SNAT.
Créer et déployer une tâche de migration vers le cloud
Connectez-vous à la console ApsaraMQ for Kafka. Sur la page Overview, sélectionnez une région dans la section Resource Distribution.
Dans le volet de navigation de gauche, cliquez sur Migration, puis sur Cloud Migration.
Sur l'onglet Cloud Migration, cliquez sur Create Task.
-
Dans le panneau Create Cloud Migration Task, configurez les paramètres suivants.
Sur l'onglet Configure Basic Information, spécifiez un Task Name et sélectionnez une Destination Instance, puis cliquez sur Next.
-
Sur l'onglet Configure Source Service, configurez les paramètres du service source, puis cliquez sur Next.
-
Si vous sélectionnez VPC (Interconnection Between Self-managed Instance and VPC) pour Source Instance Type, configurez les paramètres suivants.
Paramètre
Description
Exemple
Source Region
Sélectionnez la
regionde l'instancesource.China (Hangzhou)
Endpoint
L'
endpointde l'instancesource.192.168.XX.XX:9092
VPC ID
Cette valeur est renseignée automatiquement en fonction du VPC de l'
instancesource et ne peut pas être modifiée.vpc-test-c****
vSwitch ID
Le
vSwitch IDde l'instancesource.vsw-bp1gbjqsf53og****
Security Group
Sélectionnez le
security groupde l'instancesource.alikafka_pre-cn-7mz2****
Security Protocol
Sélectionnez le
security protocolde l'instancesource.-
PLAINTEXT
-
SASL_PLAINTEXT
-
SASL Username : saisissez le nom d'utilisateur SASL.
-
SASL Password : saisissez le mot de passe SASL.
-
SASL mechanism : mécanisme d'authentification SASL. Valeurs valides : PLAIN, SCRAM-SHA-256 et SCRAM-SHA-512.
-
-
SASL_SSL
-
SASL Username : saisissez le nom d'utilisateur SASL.
-
SASL Password : saisissez le mot de passe SASL.
-
SASL mechanism : mécanisme d'authentification SASL. Valeurs valides : PLAIN, SCRAM-SHA-256 et SCRAM-SHA-512.
-
SSL Truststore File : téléchargez le fichier de certificat.
-
SSL Truststore Password : saisissez le mot de passe du certificat.
-
SSL Endpoint Identification Algorithm : algorithme utilisé pour vérifier l'identité du serveur lors de la communication SSL, ce qui permet de prévenir les attaques de type « man-in-the-middle ». Vous pouvez saisir
https,httpou laisser le champ vide.
-
PLAINTEXT
Number of Tasks
Sélectionnez le nombre de tâches pour la synchronisation des données. Valeurs valides :
-
1
-
6
-
12
12
Synchronize SASL Users
Détermine s'il faut synchroniser les utilisateurs SASL lors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.
Yes
Synchronize Topic ACLs
Détermine s'il faut synchroniser les ACL de
topiclors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.-
Yes : synchronise les ACL de
topicde l'instancesource vers l'instancede destination. Si l'instancesource est unself-managed cluster, vous devez créer manuellement des utilisateurs SASL sur l'instancede destination pour synchroniser les ACL detopic. -
No : ne synchronise pas les ACL de
topicde l'instancesource vers l'instancede destination.
Yes
Synchronize Consumer Groups
Détermine s'il faut synchroniser les
consumer groups de l'instancesource vers l'instancede destination lors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.Yes
Synchronize Consumer Offsets
Détermine s'il faut synchroniser les
consumer offsets de l'instancesource vers l'instancede destination lors de la migration des données. Ce paramètre n'apparaît que lorsque vous cliquez sur Configure Runtime Environment et définissez Synchronize Consumer Groups sur Yes. La valeur par défaut est Yes.Yes
Topic
Les
topics de l'instancesource à synchroniser vers l'instancede destination. Si vous laissez ce paramètre vide, tous lestopics sont synchronisés. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment.test-topic
Create Topics to Use Local Storage
Spécifiez quels
topics non compactés créer avec unlocal storagesur l'instancede destination. Si vous laissez ce paramètre vide, lestopics sont créés avec uncloud storage. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment.test-topic
-
-
Si vous sélectionnez Public Network (IDC or Cross-cloud Instance) pour Source Instance Type, configurez les paramètres suivants.
Paramètre
Description
Exemple
Endpoint
L'
endpointde l'instancesource.192.168.XX.XX:9092
Security Group
Sélectionnez le
security groupde l'instancesource.alikafka_pre-cn-7mz2****
Security Protocol
Sélectionnez le
security protocolde l'instancesource.-
PLAINTEXT
-
SASL_PLAINTEXT
-
SASL Username : saisissez le nom d'utilisateur SASL.
-
SASL Password : saisissez le mot de passe SASL.
-
SASL mechanism : mécanisme d'authentification SASL. Valeurs valides : PLAIN, SCRAM-SHA-256 et SCRAM-SHA-512.
-
-
SASL_SSL
-
SASL Username : saisissez le nom d'utilisateur SASL.
-
SASL Password : saisissez le mot de passe SASL.
-
SASL mechanism : mécanisme d'authentification SASL. Valeurs valides : PLAIN, SCRAM-SHA-256 et SCRAM-SHA-512.
-
SSL Truststore File : téléchargez le fichier de certificat.
-
SSL Truststore Password : saisissez le mot de passe du certificat.
-
SSL Endpoint Identification Algorithm : algorithme utilisé pour vérifier l'identité du serveur lors de la communication SSL, ce qui permet de prévenir les attaques de type « man-in-the-middle ». Vous pouvez saisir
https,httpou laisser le champ vide.
-
PLAINTEXT
Number of Tasks
Sélectionnez le nombre de tâches pour la synchronisation des données. Valeurs valides :
-
1
-
6
-
12
12
Synchronize SASL Users
Détermine s'il faut synchroniser les informations des utilisateurs SASL vers l'
instancede destination lors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.Yes
Synchronize Topic ACLs
Détermine s'il faut synchroniser les ACL de
topiclors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.-
Yes : synchronise les ACL de
topicde l'instancesource vers l'instancede destination. Si l'instancesource est unself-managed cluster, vous devez créer manuellement des utilisateurs SASL sur l'instancede destination pour synchroniser les ACL detopic. -
No : ne synchronise pas les ACL de
topicde l'instancesource vers l'instancede destination.
Yes
Synchronize Consumer Groups
Détermine s'il faut synchroniser les
consumer groups de l'instancesource vers l'instancede destination lors de la migration des données. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment. La valeur par défaut est Yes.Yes
Synchronize Consumer Offsets
Détermine s'il faut synchroniser les
consumer offsets de l'instancesource vers l'instancede destination lors de la migration des données. Ce paramètre n'apparaît que lorsque vous cliquez sur Configure Runtime Environment et définissez Synchronize Consumer Groups sur Yes. La valeur par défaut est Yes.Yes
Topic
Les
topics de l'instancesource à synchroniser vers l'instancede destination. Si vous laissez ce paramètre vide, tous lestopics sont synchronisés. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment.test-topic
Create Topics to Use Local Storage
Spécifiez quels
topics non compactés créer avec unlocal storagesur l'instancede destination. Si vous laissez ce paramètre vide, lestopics sont créés avec uncloud storage. Ce paramètre apparaît après avoir cliqué sur Configure Runtime Environment.test-topic
-
-
Sur l'onglet Configure Destination Service, cliquez sur Create.
-
Une fois la tâche créée, sur la page Migration, sélectionnez l'instance cible dans la liste déroulante Instance. Dans la liste des instances, repérez la tâche que vous avez créée et cliquez sur Deploy dans la colonne Actions.
Sur la page Migration, si le Status de la tâche est Running, la tâche est déployée avec succès.
Autres opérations
Sur la page Migration, sélectionnez l'instance concernée dans la liste déroulante Instance, repérez la tâche et utilisez les options de la colonne Actions.
Afficher les détails de la tâche : cliquez sur Details. Sur la page des détails de la tâche, consultez les sections Basic Information, Source Service, Destination Service et Runtime Environment.
Afficher la progression de la synchronisation : cliquez sur Synchronization Progress, sélectionnez le
topicà afficher, puis cliquez sur OK.Modifier la configuration de la tâche : cliquez sur Modify Configuration. Dans le panneau qui s'affiche, modifiez les paramètres de la tâche selon vos besoins.
Réinitialiser les offsets des consommateurs : choisissez , définissez le
topicet la méthode de réinitialisation, puis cliquez sur OK. Pour plus d'informations sur la réinitialisation desconsumer offsets, consultez Réinitialiser les offsets des consommateurs.Pour démarrer ou arrêter une tâche, sélectionnez ou . Ensuite, dans la boîte de dialogue Note, cliquez sur OK.
Pour supprimer une tâche, sélectionnez , puis cliquez sur OK dans la boîte de dialogue Note.