Kafka消息刪除策略可以通過以下幾個屬性進行配置:
retention.ms
:該屬性指定消息在日志中的保留時間。默認值為7天。你可以根據需要調整該值來設置消息的保留時間。
cleanup.policy
:該屬性指定了刪除策略。有以下幾種可選的值:
delete
:表示消息在保留時間過期后將被刪除。compact
:表示消息在保留時間過期后將被壓縮(只保留最后一次更新的消息)。delete,compact
:表示消息既會被刪除,也會被壓縮。min.cleanable.dirty.ratio
:該屬性指定了在進行日志清理(刪除或壓縮)前,最小的臟數據比例。默認值為0.5,表示當臟數據的比例達到50%時才執行日志清理操作。
這些屬性可以在Kafka的配置文件(例如server.properties
)中進行配置。你可以根據需要修改這些屬性的值,并重啟Kafka Broker使配置生效。