OnsConsumerResetOffset - : Central de Documentação do Alibaba Cloud

Observação

Use esta operação para limpar mensagens em fila ou reprocessar mensagens. Você pode limpar as mensagens em fila pelos seguintes métodos:

Limpe todas as mensagens em fila de um tópico específico.
Limpe as mensagens publicadas no tópico especificado antes de um determinado momento.

Limite de requisições

Cada conta Alibaba Cloud pode chamar esta operação até 10 vezes por segundo. Se o número de requisições enviadas em um segundo atingir esse limite, as novas requisições falharão e seus serviços poderão ser interrompidos. Para obter mais informações sobre os limites de requisição de cada operação, consulte Limites de requisição da API.

Autorização

Por padrão, contas Alibaba Cloud podem chamar esta operação. Usuários do Resource Access Management (RAM) só podem executá-la após receberem as permissões necessárias. A tabela a seguir descreve as permissões que devem ser concedidas a um usuário RAM para realizar essa chamada. Para saber como conceder permissões, consulte Políticas.

API

Action

Recurso em uma instância com namespace

Recurso em uma instância sem namespace

OnsConsumerResetOffset

mq:QueryInstanceBaseInfo

mq:ResetConsumerOffset

acs:mq:::{instanceId}%{topic}

acs:mq:::{topic}

Parâmetros da requisição

Parâmetro	Tipo	Obrigatório	Exemplo	Descrição
Action	String	Sim	OnsConsumerResetOffset	A operação a ser executada. Defina o valor como OnsConsumerResetOffset.
GroupId	String	Sim	GID_test_consumer_id	O ID do grupo de consumidores cujo offset de consumo será redefinido.
Topic	String	Sim	test-mq-topic	O nome do tópico no qual o offset de consumo será redefinido.
Type	Integer	Sim	1	O método usado para limpar mensagens em fila. Valores válidos: 0: Todas as mensagens em fila no tópico especificado são limpas. Mensagens não consumidas são ignoradas. Os consumidores do grupo especificado passam a consumir apenas as mensagens publicadas no tópico após o momento atual. Se "reconsumeLater" for retornado, as mensagens em fila não serão limpas porque o sistema está tentando reenviá-las aos consumidores. 1: As mensagens publicadas no tópico antes de um momento específico são limpas. Especifique um ponto no tempo. Os consumidores do grupo indicado consumirão apenas as mensagens publicadas no tópico após esse momento. Especifique um momento dentro do intervalo entre a publicação mais antiga e a mais recente de mensagens no tópico. Pontos fora desse intervalo são inválidos.
ResetTimestamp	Long	Não	1591153871000	O momento para redefinir o offset de consumo. Este parâmetro só tem efeito quando o parâmetro Type é definido como 1. Unidade: milissegundos.
InstanceId	String	Sim	MQ_INST_111111111111_DOxxxxxx	O ID da instância do Message Queue for Apache RocketMQ que contém o grupo de consumidores especificado.

Parâmetros de resposta

Parâmetro	Tipo	Exemplo	Descrição
RequestId	String	D52C68F8-EC5D-4294-BFFF-1A6A25AF****	O ID da requisição. O sistema gera um ID exclusivo para cada requisição. Use esse identificador para solucionar problemas.

Exemplos

Exemplos de requisições

http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerResetOffset
&GroupId=GID_test_consumer_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&Topic=test-mq-topic
&Type=1
&ResetTimestamp=1591153871000
&<Common request parameters>

Exemplos de respostas de sucesso

Formato XML

HTTP/1.1 200 OK
Content-Type:application/xml

<OnsConsumerResetOffsetResponse>
    <RequestId>D52C68F8-EC5D-4294-BFFF-1A6A25AF****</RequestId>
</OnsConsumerResetOffsetResponse>

Formato JSON

HTTP/1.1 200 OK
Content-Type:application/json

{
  "RequestId" : "D52C68F8-EC5D-4294-BFFF-1A6A25AF****"
}

Códigos de erro

Para obter uma lista de códigos de erro, visite a Central de Erros da API.

Redefinir o offset de consumo de um grupo de consumidores no console

No console do Message Queue for Apache RocketMQ, você pode redefinir o offset de consumo de um grupo de consumidores. Para mais detalhes, consulte Redefinir offsets de consumo.