Sim. O ApsaraMQ for Kafka suporta a política de limpeza compact em instâncias que executam a versão open-source 2.2.0 ou posterior.
Função da compactação de log
Por padrão, o Kafka utiliza a política de limpeza delete, que remove mensagens após atingirem um tempo de retenção ou limite de tamanho. A política de limpeza compact opera de forma distinta: ela preserva apenas o valor mais recente para cada chave de mensagem e descarta os valores anteriores.
Esse mecanismo é útil quando você precisa apenas do estado atual de um registro, e não de seu histórico completo. Os cenários de uso mais comuns incluem:
Captura de alterações de banco de dados: mantém um changelog compactado com atualizações de linhas, conservando somente a versão mais recente de cada linha.
Armazenamento de configurações ou metadados: armazena configurações de aplicação como pares chave-valor, em que apenas a definição mais recente é relevante.
Estado de sessão: rastreia o estado de sessão mais recente por usuário ou dispositivo, sem acumular entradas expiradas.
Requisito de versão
A política de limpeza compact exige a versão open-source 2.2.0 ou posterior. Caso sua instância execute uma versão anterior, faça o upgrade antes de prosseguir. Para obter as etapas necessárias, consulte Fazer upgrade da versão principal de uma instância.