Kafka的topic可以通过配置不同的保留策略来控制消息的存储时间。以下是Kafka中常见的两种消息保留策略：
在Kafka中，可以为每个topic设置一个消息保留时间，即消息在topic中的最长存活时间。当消息超过这个时间后，它将被自动删除。这个时间可以通过配置文件中的log.retention.hours（小时）、log.retention.minutes（分钟）或log.retention.ms（毫秒）参数来设置。需要注意的是，这个时间是针对每个分区的，而不是整个topic。因此，如果一个topic有多个分区，那么每个分区的消息保留时间可能不同。
除了基于时间的保留策略外，Kafka还支持基于大小的保留策略。这种策略可以根据消息的大小来决定是否删除旧消息。当消息的总大小超过配置的阈值时，Kafka将自动删除最旧的消息。这个阈值可以通过配置文件中的log.retention.bytes参数来设置。同样需要注意的是，这个大小是针对每个分区的，而不是整个topic。
在实际应用中，可以根据业务需求选择合适的保留策略。例如，如果需要根据时间保留日志以便进行审计或分析，可以选择基于时间的保留策略；如果需要根据消息大小来控制存储空间的使用，可以选择基于大小的保留策略。
需要注意的是，Kafka并不会立即删除过期的消息，而是会在后台定期进行清理操作。因此，在实际使用中，可能会发现一段时间后topic的大小并没有明显减小，这是因为Kafka正在进行清理操作。
