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 acumulação de mensagens.

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

• Se houver grande acumulação de mensagens, compare as taxas de consumo e produção. Quando a taxa de consumo for inferior à de produção, aumente a capacidade de consumo.

Visualizar grupos que assinam um tópico

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

2. Na página Instances, clique no 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 na 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 exibe os detalhes de consumo de cada partição do tópico.

   Parâmetro	Descrição
   Partition ID	O ID da partição do tópico.
   Client	O consumidor online atualmente inscrito no tópico. Nota O valor segue o formato <Client ID>_/<IP>. Informações de client para consumidores offline não estão disponíveis.
   Maximum Offset	O offset máximo do consumidor na partição.
   Consumer Offset	O offset atual do consumidor na partição.
   Messages Accumulated	O número de mensagens acumuladas na partição, calculado como Maximum Offset - Consumer Offset. Importante A contagem de mensagens acumuladas é uma métrica essencial. Um valor elevado pode indicar que os consumidores estão bloqueados ou que o consumo está mais lento que a produção. Analise o status do consumidor e aumente a capacidade de consumo conforme necessário. Para obter mais informações, consulte Reset consumer offsets.

Visualizar tópicos assinados por um grupo

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

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

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

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

   A lista exibe todos os tópicos assinados pelo grupo e o campo Messages Accumulated para cada tópico.

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

   A lista Consumer Details exibe 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

Acumulação de mensagens com consumidor ativo

O consumidor pode estar usando o modo de consumo assign, que exige gerenciamento manual de offsets. As mensagens podem aparecer como acumuladas se o offset do consumidor não tiver sido confirmado, mesmo após o consumo. Para resolver esse problema, 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 sua própria thread, ou implante múltiplos processos consumidores. Se o número de instâncias de consumidor exceder o número de partições, a velocidade de consumo não aumentará e algumas instâncias ficarão ociosas.

• Aumente o número de threads de consumo. Para obter mais informações, consulte Increase consumption speed.

A acumulação de mensagens indica sempre um problema?

Não necessariamente. Considere os seguintes cenários:

• O último horário de consumo é recente e as mensagens acumuladas oscilam dentro de um intervalo estável, sem crescimento contínuo. Esse comportamento é normal e indica que o client está buscando ativamente as mensagens mais recentes.

• As mensagens acumuladas crescem continuamente enquanto o offset do consumidor permanece inalterado. Isso indica que a thread do consumidor está bloqueada, parou de processar mensagens e não está mais confirmando offsets — situação anormal que representa acumulação real.

• As mensagens acumuladas crescem enquanto o offset do consumidor também avança. Nesse caso, o client ainda está consumindo, mas a taxa de consumo é inferior à de produção. Aumente a capacidade de consumo.

Para obter mais informações, consulte Troubleshoot message accumulation in 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 obter mais informações, consulte Reset consumer offsets.