消息的过期时间
我们在使用Kafka存储消息时，如果已经消费过了，再永久存储是一种资源的浪费，所有，kafka为我们提供了消息文件的过期策略，可以通过配置server.properies来实现
# vi config/server.properies
修改下面的代码
log.roll.hours=1
log.retention.hours=2
log.segment.delete.delay.ms=0
重启kafka服务即可，上面表示消息存储时间为２小时。
设置单个topic的过期时间：
cleanup.policy=delete
file.delete.delay.ms=60000
retention.ms=86400000 为一天，单位是毫秒。
retention.ms=259200000 三天
retention.ms=172800000 2天
