Em caso de exceção no consumo de mensagens, visualize o status de um grupo de consumidores (Group) específico no console do ApsaraMQ for RocketMQ. Essas informações incluem status online dos consumidores, consistência das assinaturas, métricas de acúmulo de mensagens e dados dos clientes consumidores, o que permite identificar rapidamente a causa da exceção.
Casos de uso
Informações sobre o status do consumidor, como disponibilidade online, assinaturas, TPS de consumo, acúmulo de mensagens e stack trace de threads, são frequentemente usadas para solução de problemas nos seguintes cenários:
|
Cenário |
Sintoma |
Ação recomendada |
|
Assinaturas inconsistentes |
Na página Group Details, o status de Subscriptions do grupo de consumidores exibe a mensagem Subscriptions are inconsistent. Fix the issue promptly.. |
Consulte Assinaturas inconsistentes. |
|
Acúmulo de mensagens |
Na página Group Details, os valores de Inflight Messages, Ready Messages e Queuing Time estão acima do esperado. |
Consulte Como lidar com o acúmulo de mensagens. |
Informações do grupo de consumidores
Procedimento
Faça login no console do ApsaraMQ for RocketMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior, selecione uma região, como China (Hangzhou). Na página Instances, clique em nome da instância que deseja gerenciar.
No painel de navegação à esquerda, clique em Groups. Em seguida, na lista de grupos, clique em grupo desejado.
Resultados
A tabela a seguir descreve os campos desta página.
|
Campo |
Descrição |
|
Consumer Status |
|
|
Consumption Mode |
Modo usado pelos consumidores para assinar mensagens. O ApsaraMQ for RocketMQ oferece suporte aos modos de consumo por cluster e por broadcast, sendo o modo por cluster o padrão. Altere o modo de consumo no cliente consumidor. Para mais informações, consulte Consumo por cluster e consumo por broadcast. |
|
Real-time Consumption Rate |
TPS total de consumo de todas as instâncias consumidoras no grupo. Unidade: mensagens/segundo. |
|
Inflight Messages |
Mensagens em processamento pelos clientes consumidores sem resultado de consumo retornado. |
|
Ready Messages |
Mensagens prontas e disponíveis para consumo no servidor do ApsaraMQ for RocketMQ. |
|
Queuing Time |
Tempo decorrido desde que a mensagem pronta mais antiga ficou disponível. Esse valor reflete a tempestividade do pull de mensagens pelos consumidores. |
|
Subscriptions |
Indica se as assinaturas das instâncias consumidoras no grupo são consistentes e exibe as tags assinadas por cada cliente consumidor. Para mais detalhes sobre consistência de assinaturas, consulte Consistência de assinaturas. O ApsaraMQ for RocketMQ permite visualizar assinaturas apenas de clientes online. |
|
Client Connection Information |
Exibe informações sobre os clientes consumidores atualmente online, incluindo endereços IP, versões do cliente e stack trace. |
Acúmulo de mensagens
Procedimento
Na página Groups, clique em Dashboard.
Também é possível usar o painel para visualizar todas as métricas de uma instância específica. Para mais informações, consulte Painel.
Resultados
O painel do grupo de consumidores exibe métricas relacionadas aos cenários de consumo do grupo atual. Isso inclui o acúmulo de mensagens e a taxa de consumo do grupo em um tópico especificado, além de gráficos de tendências que mostram variações no acúmulo de mensagens e nas taxas de produção/consumo desse tópico.
Ao encontrar uma exceção de consumo, siga estas etapas para solucionar o problema:
Nas métricas do cenário de consumo (Figura 1), identifique o tópico com o atraso de consumo mais significativo (aquele com maior acúmulo de mensagens).
Nos critérios de filtro acima dos gráficos, selecione o tópico problemático identificado na Figura 1.
Analise as tendências de acúmulo de mensagens e as taxas de produção/consumo desse tópico nas Figuras 2 e 3 para delimitar o período da exceção.
Verifique se houve operações de backend ou exceções de rede durante esse intervalo de tempo.
Documentos relacionados
Além do console, use operações de API para consultar o status de consumo e o acúmulo de mensagens de um grupo de consumidores.