Um grupo identifica as instâncias de produtor ou consumidor que processam o mesmo tipo de mensagem com uma lógica compartilhada. Crie os grupos no console do ApsaraMQ for RocketMQ antes de usar o ApsaraMQ for RocketMQ para produzir ou consumir mensagens.
Limites
Até 1.000 grupos por instância. Reutilize ou exclua grupos não utilizados para permanecer dentro do limite. Para aumentar essa cota, entre em contato com o suporte técnico do ApsaraMQ for RocketMQ.
Não é possível usar um grupo em diferentes instâncias.
-
O ApsaraMQ for RocketMQ oferece suporte aos protocolos http e TCP para o consumo de mensagens. Grupos diferentes podem usar protocolos diferentes, mas todos os consumidores dentro do mesmo grupo devem usar o mesmo protocolo.
O uso de protocolos mistos em um mesmo grupo pode causar falhas no consumo, duplicação ou perda de mensagens.
Alterações de protocolo em um grupo levam de 1 a 2 horas para entrar em vigor.
Se o protocolo real for diferente do exibido no console, os dados do console podem ficar imprecisos, mas o fluxo de mensagens não será afetado. Entre em contato com o suporte técnico do ApsaraMQ for RocketMQ para atualizar o protocolo exibido.
O id de grupo é obrigatório para cada consumidor, mas opcional para os produtores.
Convenções de nomenclatura para ids de grupo
Um id de grupo deve ter de 2 a 64 caracteres e pode conter letras, dígitos, hifens (-) e sublinhados (_). Prefixo recomendado: GID_ ou GID-.
Caso a instância possua um namespace, o id do grupo precisa ser exclusivo nessa instância e não pode ser igual a nenhum id de grupo ou nome de tópico já existente. É possível usar os mesmos ids de grupo em instâncias diferentes.
Se a instância não possuir namespace, o id do grupo deve ser globalmente exclusivo em todas as instâncias e regiões da sua conta Alibaba Cloud. Ele não pode ser igual a nenhum id de grupo ou nome de tópico existente.
Para verificar se uma instância tem um namespace, acesse a página Instance Details no console do Message Queue for Apache RocketMQ e visualize a seção Basic Information.
Crie um grupo de consumidores
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 de instâncias, clique no nome da instância que deseja gerenciar.
No painel de navegação à esquerda, clique em Groups.
-
Na página Groups, selecione um protocolo para o sdk do seu cliente e clique em Create Group.
O ApsaraMQ for RocketMQ oferece suporte a TCP e HTTP para sdks de cliente.
No painel exibido, defina o Group id e a Description e clique em OK.
Exclua um grupo
Após excluir um grupo, as instâncias de consumidor identificadas por esse id de grupo param de receber mensagens. O sistema exclui permanentemente os recursos do grupo, e não é possível restaurá-los.
Na página Instances, clique no nome da instância que deseja gerenciar. No painel de navegação à esquerda da página exibida, clique em Groups.
Na lista de grupos, localize o grupo que deseja gerenciar, clique em More na coluna Actions e selecione Delete na lista suspensa.
Na mensagem exibida, clique em OK.
Visualize os detalhes de um grupo
Na página Instances, clique no nome da instância que deseja gerenciar. No painel de navegação à esquerda da página exibida, clique em Groups.
Na lista de grupos, localize o grupo de destino e clique em seu id ou em Details na coluna Actions para abrir a página de detalhes do grupo.
Mais operações
A página Groups também oferece suporte a estas operações:
No painel de navegação à esquerda, clique em Groups.
Na lista de grupos, localize o grupo que deseja gerenciar, clique em More na coluna Actions e selecione uma das seguintes operações na lista suspensa:
Quick Access: visualize as referências do sdk do ApsaraMQ for RocketMQ para várias linguagens de programação.
Reset Consumer Offset: Redefina o offset do consumidor para ignorar mensagens acumuladas ou indesejadas e inicie o consumo a partir de um novo offset. Você também pode consumir mensagens a partir de um ponto específico no tempo, independentemente de as mensagens anteriores terem sido consumidas. Para mais informações, consulte Reset consumer offsets.
Cloud Monitor: visualize os dados de monitoramento de produção e consumo do grupo.
Dashboard: visualize as métricas de consumo do grupo.
Referências
Também é possível gerenciar grupos por meio das seguintes operações de API:
OnsGroupCreate: Cria um grupo.
OnsGroupDelete: Exclui um grupo.
OnsGroupList: Consulta todos os grupos em uma instância.
OnsGroupSubDetail: Consulta os tópicos nos quais um grupo está inscrito.
OnsGroupConsumerUpdate: Atualize as permissões de leitura e gravação para um grupo.