ApsaraMQ for Kafka conserve les messages pendant une période configurable. À l'expiration de cette période, le système supprime automatiquement les messages. Définissez la durée de conservation au niveau de l'instance, du topic ou des deux.
Niveaux de configuration
La durée de conservation des messages accepte deux niveaux de configuration :
Niveau instance (
log.retention.hours) : s'applique à tous les topics de l'instance comme durée de conservation par défaut.Niveau topic (
retention.ms) : s'applique à un topic spécifique. La configuration au niveau du topic prévaut sur celle du broker.
Si aucune durée de conservation n'est définie au niveau du topic, celui-ci hérite de la valeur définie au niveau de l'instance.
Prise en charge de la conservation selon le type d'instance
Les instances Kafka existent en deux versions principales : V2 (provisionnée) et V3 (Serverless). Les paramètres de conservation disponibles dépendent de l'édition de l'instance et de la classe de stockage du topic.
| Version de l'instance | Édition | Conservation au niveau de l'instance | Conservation au niveau du topic | Notes |
|---|---|---|---|---|
| V3 (Serverless) | -- | Pris en charge | Pris en charge | Les deux niveaux sont pris en charge, quel que soit le type de stockage |
| V2 (provisionnée) | Standard Edition | Pris en charge | Non pris en charge | Uniquement au niveau de l'instance |
| V2 (provisionnée) | Professional Edition | Pris en charge | Pris en charge | Conservation au niveau du topic uniquement pour les topics utilisant un stockage local |
Paramètres de configuration
| Paramètre | Portée | Unité | Description |
|---|---|---|---|
log.retention.hours |
Instance | Heures | Durée de conservation par défaut des messages pour tous les topics de l'instance |
retention.ms |
Topic | Millisecondes | Durée de conservation pour un topic spécifique. Remplace log.retention.hours |
Comportement spécifique à l'édition
L'édition Standard V2 prend en charge uniquement la conservation au niveau de l'instance.
L'édition Professional V2 prend en charge la conservation au niveau du topic uniquement pour les topics utilisant un stockage local.
Les instances V3 prennent en charge la conservation aux niveaux instance et topic pour tous les topics, quel que soit le type de stockage.
Si
log.retention.hoursetretention.mssont configurés simultanément,retention.msa la priorité pour ce topic.