OnsConsumerResetOffset - - Centro de documentación de Alibaba Cloud

Restablece el desplazamiento del consumidor de un grupo de consumidores a una marca de tiempo específica.

Nota

Puede llamar a esta operación para borrar los mensajes en cola o volver a consumirlos. Para borrar los mensajes en cola, utilice uno de los siguientes métodos:

Borre todos los mensajes en cola de un tema específico.
Borre los mensajes publicados en el tema especificado antes de un momento determinado.

Límite de solicitudes

Cada cuenta de Alibaba Cloud puede llamar a esta operación hasta 10 veces por segundo. Si la cantidad de solicitudes enviadas en un segundo alcanza este límite, las nuevas solicitudes fallarán, lo cual podría interrumpir su servicio. Para obtener más información sobre los límites de solicitud de cada operación, consulte Límites de solicitud de API.

Autorización

De forma predeterminada, las cuentas de Alibaba Cloud pueden llamar a esta operación. Un usuario de Resource Access Management (RAM) solo podrá hacerlo después de recibir los permisos necesarios. La siguiente tabla describe los permisos que se deben otorgar al usuario de RAM para ejecutar esta operación. Para obtener información sobre cómo conceder permisos, consulte Políticas.

API

Acción

Recurso en una instancia con espacio de nombres

Recurso en una instancia sin espacio de nombres

OnsConsumerResetOffset

mq:QueryInstanceBaseInfo

mq:ResetConsumerOffset

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

acs:mq:::{topic}

Parámetros de solicitud

Parámetro	Tipo	Obligatorio	Ejemplo	Descripción
Action	String	Sí	OnsConsumerResetOffset	La operación que desea ejecutar. Establezca el valor en OnsConsumerResetOffset.
GroupId	String	Sí	GID_test_consumer_id	El ID del grupo de consumidores cuyo desplazamiento desea restablecer.
Topic	String	Sí	test-mq-topic	El nombre del tema en el que desea restablecer el desplazamiento del consumidor.
Type	Integer	Sí	1	El método para borrar los mensajes en cola. Valores válidos: 0: Se borran todos los mensajes en cola del tema especificado y se ignoran los no consumidos. Los consumidores del grupo indicado solo procesarán los mensajes publicados en el tema después del momento actual. Si se devuelve "reconsumeLater", significa que los mensajes en cola no se borraron porque el sistema está reintentando enviarlos a los consumidores. 1: Se borran los mensajes publicados en el tema antes de un momento específico, el cual debe indicar. Los consumidores del grupo especificado solo procesarán los mensajes publicados después de dicha marca de tiempo. La marca de tiempo debe encontrarse dentro del rango permitido, que abarca desde la primera hasta la última publicación registrada en el tema. Cualquier valor fuera de este intervalo se considerará inválido.
ResetTimestamp	Long	No	1591153871000	El momento al que desea restablecer el desplazamiento del consumidor. Este parámetro solo surte efecto cuando establece el parámetro Type en 1. Unidad: milisegundos.
InstanceId	String	Sí	MQ_INST_111111111111_DOxxxxxx	El ID de la instancia de Message Queue for Apache RocketMQ que contiene el grupo de consumidores especificado.

Parámetros de respuesta

Parámetro	Tipo	Ejemplo	Descripción
RequestId	String	D52C68F8-EC5D-4294-BFFF-1A6A25AF****	El ID de la solicitud. El sistema genera un identificador único para cada petición, el cual puede utilizar para solucionar problemas.

Ejemplos

Solicitudes de ejemplo

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>

Respuestas exitosas de ejemplo

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 error

Para consultar la lista de códigos de error, visite el Centro de errores de API.

Restablecimiento del desplazamiento del consumidor desde la consola

En la consola de Message Queue for Apache RocketMQ, puede restablecer el desplazamiento del consumidor para un grupo de consumidores. Para obtener más información, consulte Restablecer desplazamientos de consumidor.