Kafka中的消息過期策略是通過設置消息的時間戳（timestamp）和過期時間（TTL）來實現的。當消息被發送到Kafka集群時，可以為消息設置一個時間戳，然后通過配置topic的retention時間來指定消息在集群中保存的時間。當消息的時間戳超過retention時間時，消息將被刪除，即消息過期。可以通過配置topic的cleanup.policy參數來指定消息過期時的處理策略，例如刪除過期消息或將過期消息標記為刪除以等待后續清理。通過這種方式，Kafka可以自動管理消息的過期和清理，確保集群中的消息數據不會無限增長。
