Avant d'envoyer ou de recevoir des messages avec ApsaraMQ for Kafka, créez des rubriques et des groupes de consommateurs sur votre instance déployée. Les producteurs envoient des messages aux rubriques. Les consommateurs lisent les messages des rubriques via des groupes de consommateurs. Avant que les consommateurs ne puissent traiter les messages, le groupe de consommateurs doit s'abonner aux rubriques correspondantes. Un groupe de consommateurs peut s'abonner à plusieurs rubriques, et une rubrique peut desservir plusieurs groupes de consommateurs.
Prérequis
Avant de commencer, assurez-vous d'avoir :
-
Une instance ApsaraMQ for Kafka achetée et déployée
Étape 1 : Créer une rubrique
Créez des rubriques dans la même région que l'instance Elastic Compute Service (ECS) où vos producteurs et consommateurs s'exécutent. Les rubriques ne peuvent pas être utilisées entre différentes régions. Par exemple, si votre instance ECS se trouve dans la région Chine (Pékin), la rubrique doit également se trouver dans la région Chine (Pékin).
Connectez-vous à la console ApsaraMQ for Kafka.
Dans la section Resource Distribution de la page Overview, sélectionnez la région où votre instance est déployée.
Sur la page Instances, cliquez sur le nom de votre instance.
Dans le volet de navigation de gauche, cliquez sur Topics.
Sur la page Topics, cliquez sur Create Topic.
-
Dans le panneau Create Topic, configurez les paramètres suivants et cliquez sur OK. Une fois la rubrique créée, elle apparaît sur la page Topics.
**Paramètre** **Description** **Exemple** Name Le nom de la rubrique. demo Description Une brève description de la rubrique. test démo Partitions Le nombre de partitions. 12 Storage Engine Le type de moteur de stockage. Disponible uniquement pour les instances Professional Edition. L'édition Standard utilise par défaut Cloud Storage. Pour plus de détails, consultez la section Options du moteur de stockage ci-dessous. Cloud Storage Message Type Le comportement de commande des messages. Déterminé automatiquement par le moteur de stockage. Pour plus de détails, consultez la section Options du type de message ci-dessous. Normal Message Log Cleanup Policy Requis uniquement lorsque Storage Engine est défini sur Local Storage (Professional Edition). Pour plus de détails, consultez la section Options de la politique de nettoyage des journaux ci-dessous. Delete Tag Tags à associer à la rubrique. demo
Le système crée automatiquement deux rubriques internes lors du déploiement d'une instance : __alikafka_housekeeping_local_topic et __alikafka_housekeeping_cloud_topic. Ne supprimez pas ces rubriques. Pour plus d'informations, consultez Inspection description.
Options du moteur de stockage
Ce paramètre est disponible uniquement pour les instances Professional Edition. Les instances Standard Edition utilisent Cloud Storage par défaut.
Cloud Storage : Stocke les messages sur des disques Alibaba Cloud avec trois réplicas en mode distribué. Offre une faible latence, des performances élevées, une durabilité élevée et une fiabilité élevée. Si vous définissez Instance Edition sur Standard (High Write) lors de la création de l'instance, seule l'option Cloud Storage est disponible.
Local Storage : Utilise l'algorithme de réplicas synchronisés (ISR) d'Apache Kafka open source. Stocke les données avec trois réplicas en mode distribué.
Options du type de message
Normal Message : Les messages ayant la même clé sont stockés dans la même partition selon l'ordre d'envoi. En cas de panne d'un broker, l'ordre des messages entre les partitions peut ne pas être préservé. Défini automatiquement lorsque Storage Engine est défini sur Cloud Storage.
Partitionally Ordered Message : Les messages ayant la même clé sont stockés dans la même partition selon l'ordre d'envoi. En cas de panne d'un broker, l'ordre est préservé, mais certaines partitions deviennent indisponibles jusqu'à ce que le broker soit rétabli. Défini automatiquement lorsque Storage Engine est défini sur Local Storage.
Options de la politique de nettoyage des journaux
Requis uniquement lorsque Storage Engine est défini sur Local Storage (Professional Edition uniquement).
Delete (par défaut) : Conserve les messages en fonction de la période de rétention maximale. Lorsque l'utilisation du stockage dépasse 85 %, le système supprime les messages les plus anciens pour maintenir la disponibilité du service.
-
Compact : Applique la politique de compaction des journaux d'Apache Kafka. Conserve uniquement la dernière valeur pour chaque clé de message. Utilisez cette politique pour les composants qui stockent des données d'état ou de configuration, tels que Kafka Connect et Confluent Schema Registry. Pour plus d'informations, consultez aliware-kafka-demos.
ImportantLes rubriques compactées par journal sont prises en charge uniquement pour certains composants cloud-native tels que Kafka Connect et Confluent Schema Registry.
Étape 2 : Créer un groupe de consommateurs
Connectez-vous à la console ApsaraMQ for Kafka.
Dans la section Resource Distribution de la page Overview, sélectionnez la région où votre instance est déployée.
Sur la page Instances, cliquez sur le nom de votre instance.
Dans le volet de navigation de gauche, cliquez sur Groups.
Sur la page Groups, cliquez sur Create Group.
Dans le panneau Create Group, saisissez un nom de groupe dans le champ Group ID et une description dans le champ Description, associez des tags si nécessaire, puis cliquez sur OK. Une fois le groupe de consommateurs créé, il apparaît sur la page Groups.
Étapes suivantes
Après avoir créé des rubriques et des groupes de consommateurs, utilisez un SDK pour produire et consommer des messages. Consultez Étape 4 : Utiliser un SDK pour envoyer et recevoir des messages.
Rubriques connexes
Pour activer la création automatique de ressources, consultez Créer automatiquement des rubriques et Utiliser la fonctionnalité de création flexible de groupes.
Pour créer des ressources par programmation, consultez les références API CreateTopic et CreateConsumerGroup.