ApsaraMQ for Kafka:Consultar mensagens

Observações

• O console do ApsaraMQ for Kafka exibe no máximo 1 KB de conteúdo por mensagem consultada. O conteúdo que exceder 1 KB é truncado automaticamente. Para visualizar o conteúdo completo da mensagem, baixe-a. O tamanho máximo de uma mensagem baixada é 10 MB. Se a mensagem tiver mais de 10 MB, apenas os primeiros 10 MB do conteúdo são baixados.

• Os resultados da consulta exibem no máximo 10 mensagens, cujo tamanho total não pode exceder 10 MB.

  • Por exemplo, se o tamanho total das três primeiras mensagens exceder 10 MB, apenas as duas primeiras serão exibidas.

  • Se o tamanho total das 10 mensagens for inferior a 10 MB, todas as 10 mensagens serão exibidas.

• A possibilidade de consultar uma mensagem depende das políticas de limpeza de mensagens do ApsaraMQ for Kafka:

  • Se o uso do disco for inferior a 75%, as mensagens que excederem o período de retenção são excluídas às 04h00 todos os dias.

  • Se o uso do disco estiver entre 75% e 85% (exclusive), as mensagens que excederem o período de retenção são excluídas até que o uso do disco caia abaixo de 75%.

  • Se o uso do disco estiver entre 85% e 90% (exclusive), as mensagens armazenadas mais antigas são removidas, independentemente do período de retenção.

  • Se o uso do disco for igual ou superior a 90%, a proteção contra gravação é ativada para garantir a estabilidade do service. Novas mensagens não podem ser gravadas.

  Importante

  Quando o ApsaraMQ for Kafka remove mensagens, pelo menos um arquivo de armazenamento é mantido. Portanto, pode ser possível consultar mensagens que já ultrapassaram o período de retenção.

Consultar mensagens por offset

1. Acesse o console do ApsaraMQ for Kafka.

2. Na página Overview, selecione uma região na seção Resource Distribution.

3. Na página Instances, clique em o nome da instância desejada.

4. No painel de navegação à esquerda, clique em Message Query.

5. Na página Message Query, selecione Search by offset na lista suspensa Search Method.

6. Na lista Topic, selecione um tópico. Na lista Partition, selecione uma partição. No campo Offset, insira o offset da mensagem e clique em Search.

   Os resultados exibem a mensagem no offset especificado e as mensagens subsequentes. Por exemplo, se você selecionar a partição 5 e definir o offset inicial como 5, os resultados começarão a partir do offset 5 na partição 5.

   Tabela 1. Parâmetros dos resultados da consulta

   Parâmetro	Descrição
   Partition	A partição do tópico à qual a mensagem pertence.
   Offset	O offset da mensagem.
   Key	A chave da mensagem, convertida para string.
   Value	O valor da mensagem, que corresponde ao conteúdo da mensagem, convertido para string.
   Headers	As informações de cabeçalho da mensagem, exibidas como pares chave-valor, por exemplo, [trace-id=123]. Se não configurado, o valor padrão é [].
   CompressionType	O tipo de compactação utilizado na mensagem. O valor padrão é none, indicando que não há compactação.
   Created At	O horário de criação da mensagem no objeto ProducerRecord, especificado por você ou incluído pelo cliente no momento do envio. Nota Se este campo estiver configurado, o valor configurado é exibido. Se este campo não estiver configurado, o horário do sistema no momento do envio é usado por padrão. Se o valor exibido estiver no formato 1970/x/x x:x:x, o horário de envio foi configurado como 0 ou outro valor inválido. ApsaraMQ for Kafka clientes de versão 0,9 e anteriores não oferecem suporte à configuração deste horário.
   Actions	Clique em Download Key para baixar a chave da mensagem. Clique em Download Value para baixar o conteúdo da mensagem.

Consultar mensagens por tempo

É possível consultar mensagens de todas as partições por tempo. Se você não sabe a localização da mensagem, mas conhece o momento aproximado em que ela foi enviada, especifique um ponto no tempo. A consulta retorna as mensagens enviadas a partir do horário especificado.

1. Na página Message Query, selecione Search by Point in Time na lista suspensa Search Method.

2. Na lista Topic, selecione um tópico. Na lista Partition, selecione uma partição. Na seção Point in Time, selecione um horário e clique em Search.

   As mensagens enviadas a partir do ponto no tempo especificado são exibidas. Para obter informações sobre os parâmetros dos resultados da consulta, consulte Query result parameters.

   • Se você selecionar All Partitions, as mensagens de todas as partições serão exibidas.

   • Se você selecionar uma partição específica, apenas as mensagens dessa partição serão exibidas.

Referências

• Para obter mais informações sobre offsets, consulte Terms.

• Para obter mais informações sobre detalhes de consumo de mensagens, consulte View consumer status.