在Kafka中，消息的過期時間是通過在Producer端設置消息的時間戳來控制的。在發送消息時，可以通過設置消息的時間戳來指定消息的過期時間，一旦消息的時間戳超過了設置的過期時間，Kafka會自動刪除該消息。
具體來說，在Producer端可以通過以下幾種方式來設置消息的時間戳和過期時間：
使用消息的時間戳屬性：在發送消息時，可以通過設置消息的時間戳屬性來指定消息的時間戳?？梢允褂?code>producer.send(new ProducerRecord(topic, key, value, timestamp))方法來發送帶有時間戳的消息。
使用消息的Key和Value：在發送消息時，可以將消息的過期時間信息嵌入到消息的Key或Value中，然后在Consumer端讀取消息時進行判斷。例如，可以在消息的Key或Value中添加一個過期時間字段，然后在Consumer端讀取消息時判斷該字段是否超過了當前時間，如果超過了則丟棄消息。
使用Kafka的日志清理策略：Kafka提供了配置參數log.retention.hours和log.retention.ms來設置消息的過期時間?？梢酝ㄟ^配置這些參數來控制消息在Kafka中的保留時間，超過指定時間后消息會被自動刪除。
總的來說，通過在Producer端設置消息的時間戳或在消息中嵌入過期時間信息，并通過Kafka的日志清理策略來控制消息的過期時間，可以實現消息的自動過期和清理。
