ApsaraMQ for Kafka:Visualizar status do consumidor

Observações

• Um grupo de consumidores não deve assinar mais de três tópicos para evitar acúmulo de mensagens.

• Ao usar o modo de consumo assign, confirme os offsets do consumidor prontamente. Isso evita que mensagens já consumidas apareçam como acumuladas devido a offsets não confirmados.

• Se houver grande acúmulo de mensagens, compare as taxas de consumo e produção. Caso a taxa de consumo seja inferior à de produção, aumente a capacidade de consumo.

Visualizar grupos que assinam um tópico

1. Faça login no console do ApsaraMQ for Kafka. Na página Overview, selecione uma região na seção Resource Distribution.

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

3. No painel de navegação à esquerda, clique em Topics.

4. Na página Topics, clique em Name do tópico desejado.

5. Na página Topic Details, clique em aba Subscriptions.

   A lista Online groups that subscribe to the topic exibe todos os grupos online que assinam este tópico.

6. Na lista Online groups that subscribe to the topic, localize o grupo desejado e clique em Consumer Details na coluna Actions.

   A lista apresenta os detalhes de consumo de cada partição do tópico.

   Parâmetro	Descrição
   Partition ID	ID da partição do tópico.
   Client	Consumidor online atualmente assinante do tópico. Nota O valor segue o formato <Client ID>_/<IP>. As informações de clientes para consumidores offline não estão disponíveis.
   Maximum Offset	Offset máximo do consumidor na partição.
   Consumer Offset	Offset atual do consumidor na partição.
   Messages Accumulated	Quantidade de mensagens acumuladas na partição, calculada como Maximum Offset - Consumer Offset. Importante A contagem de mensagens acumuladas é uma métrica essencial. Um valor elevado pode indicar bloqueio nos consumidores ou consumo mais lento que a produção. Analise o status do consumidor e aumente a capacidade de consumo conforme necessário. Para mais informações, consulte Redefinir offsets de consumidor.

Visualizar tópicos assinados por um grupo

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

2. No painel de navegação à esquerda, clique em Groups.

3. Na página Groups, clique em Group ID desejado.

4. Na página Group Details, clique em aba Consumer Status.

   A lista exibe todos os tópicos assinados pelo grupo e as Messages Accumulated de cada tópico.

5. Na lista Topic, localize o tópico desejado e clique em Consumer Details na coluna Actions.

   A lista Consumer Details apresenta os detalhes de consumo do grupo para cada partição do tópico.

   Para descrições dos parâmetros, consulte a tabela acima.

Perguntas frequentes

Acúmulo de mensagens com consumidor ativo

O consumidor pode estar usando o modo de consumo assign, que exige gerenciamento manual de offsets. As mensagens podem parecer acumuladas se o offset do consumidor não tiver sido confirmado, mesmo após o consumo. Para resolver, confirme o offset do consumidor prontamente.

Como aumentar a capacidade de consumo

Aumente a capacidade de consumo das seguintes formas:

• Aumente o número de instâncias de consumidor. Adicione instâncias dentro de um processo, cada uma com seu próprio thread, ou implante múltiplos processos de consumidor. Se o número de instâncias exceder o número de partições, a velocidade de consumo não aumenta e algumas instâncias ficam ociosas.

• Incremente o número de threads de consumo. Para mais informações, consulte Aumentar velocidade de consumo.

O acúmulo de mensagens sempre indica um problema?

Nem sempre. Considere os seguintes cenários:

• A última hora de consumo é recente e as mensagens acumuladas flutuam dentro de uma faixa estável, sem crescimento contínuo. Isso é normal e indica que o cliente está buscando ativamente as mensagens mais recentes.

• As mensagens acumuladas crescem constantemente enquanto o offset do consumidor permanece inalterado. Isso indica que o thread do consumidor está bloqueado, parou de processar mensagens e não está mais confirmando offsets. Trata-se de uma situação anormal, significando que as mensagens realmente se acumularam.

• As mensagens acumuladas aumentam enquanto o offset do consumidor também avança. Isso indica que o cliente ainda consome mensagens, mas o consumo está mais lento que a produção. Aumente a capacidade de consumo.

Para mais informações, consulte Solucionar problemas de acúmulo de mensagens no ApsaraMQ for Kafka.

Documentos relacionados

• Para consultar o status do consumidor via API, consulte GetConsumerProgress.

• Para ignorar mensagens acumuladas em vez de processá-las, redefina os offsets do consumidor. Para mais informações, consulte Redefinir offsets de consumidor.