ApsaraMQ for Kafka:Consulta de mensajes

Notas

• La consola de ApsaraMQ for Kafka muestra un máximo de 1 KB de contenido por cada mensaje consultado. El contenido que supera 1 KB se trunca automáticamente. Para ver el contenido completo del mensaje, descargue el mensaje. El tamaño máximo de un mensaje descargado es de 10 MB. Si un mensaje supera los 10 MB, solo se descargan los primeros 10 MB de su contenido.

• En los resultados de la consulta se muestran como máximo 10 mensajes, y su tamaño total no puede superar los 10 MB.

  • Por ejemplo, si el tamaño total de los tres primeros mensajes supera los 10 MB, solo se muestran los dos primeros.

  • Si el tamaño total de los 10 mensajes es inferior a 10 MB, se muestran los 10 mensajes.

• La posibilidad de consultar un mensaje depende de las directivas de limpieza de mensajes de ApsaraMQ for Kafka:

  • Si el uso del disco es inferior al 75 %, los mensajes que superan el periodo de retención se eliminan todos los días a las 04:00.

  • Si el uso del disco está entre el 75 % y el 85 % (exclusivo), los mensajes que superan el periodo de retención se eliminan hasta que el uso del disco descienda por debajo del 75 %.

  • Si el uso del disco está entre el 85 % y el 90 % (exclusivo), se purgan los mensajes almacenados más antiguos, sin importar su periodo de retención.

  • Si el uso del disco es del 90 % o superior, se habilita la protección contra escritura para garantizar la estabilidad del servicio. No se pueden escribir mensajes nuevos.

  Importante

  Cuando ApsaraMQ for Kafka purga mensajes, conserva como mínimo un archivo de almacenamiento. Por lo tanto, es posible que pueda consultar mensajes que ya superaron su periodo de retención.

Consulta de mensajes por desplazamiento

1. Inicie sesión en la consola de ApsaraMQ for Kafka.

2. En la página Overview, seleccione una región en la sección Resource Distribution.

3. En la página Instances, haga clic en el nombre de la instancia de destino.

4. En el panel de navegación izquierdo, haga clic en Message Query.

5. En la página Message Query, seleccione Search by offset en la lista desplegable Search Method.

6. En la lista Topic, seleccione un tema. En la lista Partition, seleccione una partición. En el cuadro de texto Offset, introduzca el desplazamiento del mensaje y haga clic en Search.

   Los resultados muestran el mensaje en el desplazamiento especificado y los mensajes posteriores. Por ejemplo, si selecciona la partición 5 y establece el desplazamiento inicial en 5, los resultados comienzan desde el desplazamiento 5 en la partición 5.

   Tabla 1. Parámetros del resultado de la consulta

   Parámetro	Descripción
   Partition	La partición del tema del mensaje.
   Offset	El desplazamiento del mensaje.
   Key	La clave del mensaje. La clave se convierte en una cadena.
   Value	El valor del mensaje, que corresponde a su contenido. El valor se convierte en una cadena.
   Headers	La información del encabezado del mensaje. Se muestra como pares de clave-valor, por ejemplo, [trace-id=123]. Si no se configura, el valor predeterminado es [].
   CompressionType	El tipo de compresión que se utiliza para el mensaje. El valor predeterminado es none, lo que indica que no hay compresión.
   Created At	La hora de creación del mensaje en el objeto ProducerRecord que usted especificó o que el cliente incluyó cuando se envió el mensaje. Nota Si este campo está configurado, se muestra el valor configurado. Si este campo no está configurado, se usa de forma predeterminada la hora del sistema en la que se envió el mensaje. Si el valor mostrado tiene el formato 1970/x/x x:x:x, la hora de envío se configuró como 0 u otro valor no válido. Los clientes de ApsaraMQ for Kafka de la versión 0.9 y anteriores no admiten configurar esta hora.
   Actions	Haga clic en Download Key para descargar la clave del mensaje. Haga clic en Download Value para descargar el contenido del mensaje.

Consulta de mensajes por hora

Puede consultar mensajes de todas las particiones por hora. Si desconoce la ubicación del mensaje pero sabe aproximadamente cuándo se envió, especifique un momento determinado. La consulta devuelve los mensajes enviados en ese momento o después.

1. En la página Message Query, seleccione Search by Point in Time en la lista desplegable Search Method.

2. En la lista Topic, seleccione un tema. En la lista Partition, seleccione una partición. En la sección Point in Time, seleccione una hora y haga clic en Search.

   Se muestran los mensajes enviados en el momento especificado o después. Para obtener información sobre los parámetros de los resultados de la consulta, consulte Query result parameters.

   • Si selecciona All Partitions, se muestran los mensajes de todas las particiones.

   • Si selecciona una partición específica, solo se muestran los mensajes de esa partición.

Referencias

• Para obtener más información sobre los desplazamientos, consulte Terms.

• Para obtener más información sobre los detalles del consumo de mensajes, consulte View consumer status.