A exclusão de um Group no ApsaraMQ for Kafka não remove os offsets de consumidor armazenados no servidor. Como o sistema de alertas monitora esses offsets, os alertas de acúmulo de mensagens persistem até a limpeza dos offsets.
Esse comportamento ocorre por dois motivos:
Os offsets persistem após a exclusão. Em versões do servidor anteriores à 2.2.0 (baseadas no Apache Kafka 0.10.2), a API do Kafka não permite excluir offsets de consumidor. A exclusão de um Group apenas o remove do console, mas os dados de offset subjacentes permanecem no servidor.
Threads de consumidor continuam ativas. Mesmo após a exclusão de um Group, as threads de consumidor podem continuar em execução caso não tenham sido interrompidas explicitamente. Essas threads continuam confirmando offsets, o que dispara alertas de acúmulo.
Antes de começar
Interrompa todas as threads de consumidor no Group antes de aplicar qualquer solução abaixo. Uma thread de consumidor está ativa se assinar mensagens pelo método subscribe. Se alguma thread ainda estiver confirmando offsets, os alertas persistirão independentemente de outras ações.
Solução
Redefinir offsets de consumidor
Essa abordagem funciona em todas as versões do servidor e é a forma mais rápida de interromper os alertas.
Verifique se o Group existe no console. Caso já o tenha excluído, recrie-o.
Desconecte todas as threads de consumidor.
No console do ApsaraMQ for Kafka, redefina o offset de consumidor para 0 nas partições em que deseja parar de rastrear o acúmulo. Para obter etapas detalhadas, consulte Redefinir offsets de consumidor.
Após a redefinição, o sistema de alertas para de rastrear o acúmulo nessas partições.
Exclua o Group diretamente (versão do servidor 2.2.0 ou posterior)
Se sua instância executa a versão do servidor 2.2.0 ou posterior e o Group não possui threads de consumidor ativas, exclua o Group diretamente. O servidor remove tanto o Group quanto seus offsets de consumidor.
Caso os alertas continuem após a exclusão, verifique se nenhuma thread de consumidor ainda está confirmando offsets.
Aguardar a expiração dos offsets (versões do servidor anteriores à 2.2.0)
Em versões mais antigas do servidor, os offsets de consumidor são limpos automaticamente após o término do período de retenção, desde que nenhuma thread de consumidor os atualize. Para verificar ou ajustar o período de retenção, consulte Modifique configurações de mensagem.
Atualizar a versão do servidor (versões do servidor anteriores à 2.2.0)
Se o Group não tiver threads de consumidor ativas, atualize a versão do servidor para 2.2.0 ou posterior. Após a atualização, recrie o Group e exclua-o para remover os offsets. Para obter as etapas de atualização, consulte Atualizar versões da instância.
Desativar alertas de acúmulo de mensagens
Se nenhuma das soluções anteriores resolver o problema, desative a regra de alerta para acúmulo de mensagens no CloudMonitor. Para mais detalhes, consulte CloudMonitor.
Nas versões do servidor 2.2.0 e posteriores, os offsets de consumidor não são excluídos enquanto o Group tiver pelo menos uma thread de consumidor ativa, mesmo que os offsets excedam o período de retenção. Para mais informações, consulte Por que os offsets de consumidor não são excluídos após expirarem?.