ApsaraMQ for Kafka:Interroger des messages

Notes

• La console ApsaraMQ for Kafka affiche un maximum de 1 Ko de contenu pour chaque message interrogé. Le contenu dépassant 1 Ko est automatiquement tronqué. Pour afficher le contenu complet du message, vous pouvez le télécharger. La taille maximale d'un message téléchargé est de 10 Mo. Si un message dépasse 10 Mo, seuls les 10 premiers Mo de son contenu sont téléchargés.

• Un maximum de 10 messages s'affiche dans les résultats de la requête, et leur taille totale ne peut pas dépasser 10 Mo.

  • Par exemple, si la taille totale des trois premiers messages dépasse 10 Mo, seuls les deux premiers messages s'affichent.

  • Si la taille totale de 10 messages est inférieure à 10 Mo, les 10 messages s'affichent tous.

• La possibilité d'interroger un message dépend des politiques de nettoyage des messages de ApsaraMQ for Kafka :

  • Si l'utilisation du disque est inférieure à 75 %, les messages ayant dépassé la période de conservation sont supprimés tous les jours à 04 h 00.

  • Si l'utilisation du disque est comprise entre 75 % et 85 % (exclus), les messages ayant dépassé la période de conservation sont supprimés jusqu'à ce que l'utilisation du disque descende en dessous de 75 %.

  • Si l'utilisation du disque est comprise entre 85 % et 90 % (exclus), les messages stockés les plus anciens sont purgés, indépendamment de leur période de conservation.

  • Si l'utilisation du disque est supérieure ou égale à 90 %, la protection en écriture est activée pour garantir la stabilité du service. Les nouveaux messages ne peuvent pas être écrits.

  Important

  Lorsque ApsaraMQ for Kafka purge des messages, il conserve au moins un fichier de stockage. Par conséquent, vous pourrez peut-être interroger des messages ayant dépassé leur période de conservation.

Interroger des messages par offset

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

2. Sur la page Overview, sélectionnez une région dans la section Resource Distribution.

3. Sur la page Instances, cliquez sur le nom de l'instance cible.

4. Dans le volet de navigation de gauche, cliquez sur Message Query.

5. Sur la page Message Query, sélectionnez Search by offset dans la liste déroulante Search Method.

6. Dans la liste Topic, sélectionnez un topic. Dans la liste Partition, sélectionnez une partition. Dans la zone de texte Offset, saisissez l'offset du message et cliquez sur Search.

   Les résultats affichent le message à l'offset spécifié ainsi que les messages suivants. Par exemple, si vous sélectionnez la partition 5 et définissez l'offset de départ sur 5, les résultats commencent à l'offset 5 dans la partition 5.

   Tableau 1. Paramètres des résultats de la requête

   Parameter	Description
   Partition	La partition du topic du message.
   Offset	L'offset du message.
   Key	La clé du message. La clé est convertie en chaîne de caractères.
   Value	La valeur du message, c'est-à-dire le contenu du message. La valeur est convertie en chaîne de caractères.
   Headers	Les informations d'en-tête du message. Elles s'affichent sous forme de paires clé-valeur, telles que [trace-id=123]. Si elles ne sont pas configurées, la valeur par défaut est [].
   CompressionType	Le type de compression utilisé pour le message. La valeur par défaut est none, ce qui indique l'absence de compression.
   Created At	L'heure de création du message dans l'objet ProducerRecord que vous avez spécifié ou que le client a inclus lors de l'envoi du message. Remarque Si ce champ est configuré, la valeur configurée s'affiche. Si ce champ n'est pas configuré, l'heure système d'envoi du message est utilisée par défaut. Si la valeur affichée est au format 1970/x/x x:x:x, l'heure d'envoi a été configurée avec la valeur 0 ou une autre valeur non valide. Les clients ApsaraMQ for Kafka de version 0.9 et antérieures ne prennent pas en charge la configuration de cette heure.
   Actions	Cliquez sur Download Key pour télécharger la clé du message. Cliquez sur Download Value pour télécharger le contenu du message.

Interroger des messages par heure

Vous pouvez interroger des messages de toutes les partitions par heure. Si vous ignorez l'emplacement du message mais connaissez l'heure approximative de son envoi, vous pouvez spécifier un instant précis. La requête renvoie les messages envoyés à cet instant ou après.

1. Sur la page Message Query, sélectionnez Search by Point in Time dans la liste déroulante Search Method.

2. Dans la liste Topic, sélectionnez un topic. Dans la liste Partition, sélectionnez une partition. Dans la section Point in Time, sélectionnez une heure et cliquez sur Search.

   Les messages envoyés à l'instant spécifié ou après s'affichent. Pour plus d'informations sur les paramètres des résultats de la requête, consultez les Paramètres des résultats de la requête.

   • Si vous sélectionnez All Partitions, les messages de toutes les partitions s'affichent.

   • Si vous sélectionnez une partition spécifique, seuls les messages de cette partition s'affichent.

Références

• Pour plus d'informations sur les offsets, consultez les Termes.

• Pour plus d'informations sur les détails de la consommation des messages, consultez la rubrique Afficher l'état du consommateur.