在Kafka中,可以通過設置log.retention.hours
(以小時為單位)或log.retention.minutes
(以分鐘為單位)屬性來配置消息保留策略
打開Kafka的配置文件server.properties
。這個文件通常位于Kafka安裝目錄的config
文件夾中。
在server.properties
文件中,找到或添加以下配置項:
log.retention.hours=168
或者
log.retention.minutes=10080
其中,log.retention.hours
表示消息保留的天數(168小時等于7天),log.retention.minutes
表示消息保留的周數(10080分鐘等于7天)。
保存并關閉server.properties
文件。
重啟Kafka服務以使更改生效。具體操作取決于你的操作系統和Kafka安裝方式。一般來說,可以使用以下命令重啟Kafka服務:
sudo systemctl restart kafka
或者
service kafka restart
現在,Kafka將按照指定的保留策略刪除舊消息。請注意,這里的設置僅適用于Topic級別的消息保留。如果你需要為特定的Topic設置不同的保留策略,可以在創建Topic時通過log.retention.hours
或log.retention.minutes
屬性進行設置。