Estos contenidos se han traducido de forma automática para su comodidad, pero Huawei Cloud no garantiza la exactitud de estos. Para consultar los contenidos originales, acceda a la versión en inglés.

Centro de ayuda> Distributed Message Service for Kafka> Referencia de la API> APIs V2 (Recomendado)> Gestión de instancias> Restablecimiento de offset de grupo de consumidores en la posición especificada

Actualización más reciente 2022-11-07 GMT+08:00

Ver PDF

Restablecimiento de offset de grupo de consumidores en la posición especificada

Función

Las instancias de Kafka no admiten el restablecimiento del desplazamiento del consumidor en línea. Antes del restablecimiento, detenga el cliente para el que se va a restablecer del desplazamiento.> Después de detener un cliente, el servidor considera que el cliente está fuera de línea solo después del período de tiempo especificado en el documento ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG (1000 ms por defecto).

URI

POST /v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset

**Tabla 1** Parámetros de ruta
Parámetro	Obligatorio	Tipo	Descripción
project_id	Sí	String	ID del proyecto.
instance_id	Sí	String	ID de instancia.
group	Sí	String	Nombre del grupo de consumidores.

Parámetros de solicitud

**Tabla 2** Parámetros del cuerpo de solicitud
Parámetro	Obligatorio	Tipo	Descripción
topic	Sí	String	Nombre del tema.
partition	No	Integer	Número de partición. El valor predeterminado es -1, que indica que todas las particiones están restablecidas.
message_offset	No	Integer	Restablecimiento del desplazamiento del grupo de consumidores en la posición especificada. Si esta posición es anterior al desplazamiento más temprana actual, el desplazamiento se restablecerá a el desplazamiento más temprana. Si este desplazamiento es posterior al desplazamiento más grande actual, el desplazamiento se restablecerá al último desplazamiento. Debe especificarse message_offset or timestamp.
timestamp	No	Integer	Tiempo especificado en el que se va a restablecer el desplazamiento. El valor es una marca de tiempo Unix, en milisegundos. Si este tiempo es anterior a la marca de tiempo más antigua actual, el desplazamiento se restablecerá a la marca de tiempo más antigua. Si este tiempo es posterior a la marca de tiempo más grande actual, el desplazamiento se restablecerá a la última marca de tiempo. Debe especificarse message_offset or timestamp.

Parámetros de respuesta

Ninguno

Solicitudes de ejemplo

Restablecimiento del desplazamiento del grupo de consumidores en la posición especificada.

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset

{
  "topic" : "test",
  "partition" : 0,
  "message_offset" : 10
}

Restablecimiento del desplazamiento del grupo de consumidores a la hora especificada.

POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/management/groups/{group}/reset-message-offset

{
  "topic" : "test",
  "partition" : 0,
  "timestamp" : 1571812144000
}