Periodo de retención de mensajes para instancias de Kafka - ApsaraMQ for Kafka

ApsaraMQ for Kafka retiene los mensajes durante un periodo configurable. Una vez que este periodo expira, los mensajes se eliminan automáticamente. Establezca el periodo de retención en el nivel de instancia, en el nivel de topic o en ambos.

Niveles de configuración

El periodo de retención de mensajes admite dos niveles de configuración:

Nivel de instancia (log.retention.hours): se aplica a todos los topics de la instancia como periodo de retención predeterminado.
Nivel de topic (retention.ms): se aplica a un topic específico. La configuración de nivel de topic anula la configuración de nivel de broker.

Si no se establece una retención en el nivel de topic, este hereda el valor del nivel de instancia.

Compatibilidad de retención por tipo de instancia

Las instancias de Kafka están disponibles en dos versiones principales: V2 (provisioned) y V3 (serverless). Los ajustes de retención compatibles dependen de la edición de la instancia y de la clase de almacenamiento del topic.

Versión de la instancia	Edición	Retención en nivel de instancia	Retención en nivel de topic	Notas
V3 (serverless)	--	Compatible	Compatible	Ambos niveles son compatibles sin importar el tipo de almacenamiento
V2 (provisioned)	Standard Edition	Compatible	No compatible	Solo en nivel de instancia
V2 (provisioned)	Professional Edition	Compatible	Compatible	Retención en nivel de topic solo para topics con almacenamiento local

Parámetros de configuración

Parámetro	Ámbito	Unidad	Descripción
`log.retention.hours`	Instancia	Horas	Periodo de retención de mensajes predeterminado para todos los topics de la instancia
`retention.ms`	Topic	Milisegundos	Periodo de retención para un topic específico. Anula `log.retention.hours`

Comportamiento según la edición

V2 Standard Edition solo admite la retención en nivel de instancia.
V2 Professional Edition admite la retención en nivel de topic únicamente para los topics que usan almacenamiento local.
Las instancias V3 admiten la retención tanto en nivel de instancia como en nivel de topic para todos los topics, sin importar el tipo de almacenamiento.
Cuando se configuran log.retention.hours y retention.ms, retention.ms tiene prioridad para ese topic.