Tous les produits
Search
Centre de documentation

ApsaraMQ for Kafka:Recherche de messages

Dernière mise à jour :Sep 21, 2026

Si vous ne parvenez pas à consommer un message ou si vous constatez une perte ou un retard de messages dans ApsaraMQ for Kafka, utilisez la fonctionnalité de recherche de messages pour afficher les détails et les propriétés des messages afin de résoudre les problèmes. Si vous connaissez l'ID de partition et l'offset du message, recherchez le message par offset. Si vous ignorez l'emplacement du message mais savez quand il a été envoyé, recherchez-le par heure.

Notes

  • La console ApsaraMQ for Kafka affiche un maximum de 1 Ko de contenu pour chaque message recherché. Le contenu dépassant 1 Ko est automatiquement tronqué. Pour afficher le contenu complet du message, téléchargez-le. 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.

  • Les résultats de la recherche affichent au maximum 10 messages, 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.

  • La possibilité de rechercher 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 dont la durée de conservation est dépassée sont supprimés tous les jours à 04:00.

    • Si l'utilisation du disque est comprise entre 75 % et 85 % (exclus), les messages dont la durée de conservation est dépassée 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, quelle que soit leur durée 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, il se peut que vous puissiez rechercher des messages dont la durée de conservation est dépassée.

Recherche de 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 de la partition 5.

    Tableau 1. Paramètres des résultats de la recherche

    Paramètre

    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.

    Value

    La valeur du message, qui correspond au contenu du message. La valeur est convertie en chaîne.

    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 qu'aucune compression n'est appliquée.

    Created At

    L'heure de création du message dans l'objet ProducerRecord que vous avez spécifié ou qui est inclus par le client 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 à laquelle le message a été envoyé 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 sur 0 ou sur 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.

Recherche de messages par heure

Vous pouvez rechercher des messages de toutes les partitions par heure. Si vous ignorez l'emplacement du message mais connaissez l'heure approximative de son envoi, spécifiez un point dans le temps. La recherche renvoie les messages envoyés à l'heure spécifiée ou après celle-ci.

  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'heure spécifiée ou après celle-ci s'affichent. Pour plus d'informations sur les paramètres des résultats de la recherche, consultez la section Paramètres des résultats de la recherche.

    • 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 la section Termes.

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