Threads de consumo conseguem processar mensagens mesmo quando o grupo de consumidores correspondente não está visível no console do ApsaraMQ for Kafka. Esse comportamento ocorre por um destes três motivos.
O consumidor utiliza o modo assign
No modo assign, os consumidores atribuem partições específicas manualmente, sem depender do broker para essa distribuição. Nesse cenário, as threads de consumo processam mensagens mesmo que nenhum grupo de consumidores tenha sido criado no console.
Solução: Crie o grupo de consumidores no console do ApsaraMQ for Kafka antes de iniciar os consumidores. Sempre que possível, reutilize grupos existentes. Ultrapassar o limite de grupos de consumidores pode comprometer a estabilidade do cluster. Para mais informações, consulte Limites.
A criação automática de grupos de consumidores está ativada
Se a criação automática estiver ativada na instância do ApsaraMQ for Kafka, as threads de consumo processarão mensagens mesmo sem um grupo previamente criado.
Solução: Mesmo com a criação automática ativada, crie o grupo de consumidores antecipadamente no console do ApsaraMQ for Kafka. Essa prática mantém os grupos visíveis e facilita o gerenciamento. Reutilize grupos existentes sempre que possível. Exceder o limite de grupos pode afetar a estabilidade do cluster. Para mais informações, consulte Limites.
O grupo de consumidores foi excluído enquanto os consumidores ainda estavam em execução
No modo subscribe, se você excluir um grupo de consumidores enquanto suas threads ainda estiverem ativas, elas continuarão a consumir mensagens desde que nenhum rebalanceamento seja acionado. O grupo deixa de aparecer no console, mas as threads permanecem em execução.
Solução: Interrompa todas as threads de consumo de um grupo antes de excluí-lo.
Caso receba um alerta de acúmulo de mensagens referente a um grupo que já não aparece no console, consulte Por que ainda recebo alertas sobre acúmulo de mensagens para um grupo de consumidores após excluir o grupo?.