- 日志段（Log Segments）：Kafka将数据以日志段的形式进行存储，每个主题分区都由多个日志段组成。每个日志段都有一个开始偏移量和一个结束偏移量，表示该日志段中包含的消息范围。当一个日志段中的消息都被消费完毕后，该日志段就可以被删除。
- 消息保留策略（Message Retention Policy）：Kafka提供了多种消息保留策略来控制数据的保留时间。常见的策略有：
- 时间保留策略（Time-based Retention）：根据消息的时间戳来决定消息的保留时间。可以设置一个保留时间阈值，超过该阈值的消息将被删除。
- 大小保留策略（Size-based Retention）：根据主题分区的大小来决定消息的保留时间。可以设置一个保留大小阈值，当分区大小超过该阈值时，较早的消息将被删除。
- 日志段保留策略（Log Segments-based Retention）：根据日志段的数量来决定消息的保留时间。可以设置一个保留日志段的数量阈值，当日志段数量超过该阈值时，较早的日志段将被删除。
通过配置这些保留策略，可以灵活地控制Kafka中数据的保留时间，以满足不同业务需求和存储资源的限制。
