17.6.8. 设置消息过期

// message will expire in 5000ms from now
message.setExpiration(System.currentTimeMillis() + 5000);

// message will expire in 5000ms from now
message.setExpiration(System.currentTimeMillis() + 5000);

// messages sent by this producer will be retained for 5s (5000ms) before expiration           
producer.setTimeToLive(5000);

// messages sent by this producer will be retained for 5s (5000ms) before expiration           
producer.setTimeToLive(5000);