我有一个关于Kafka磁盘的问题。Kafka的磁盘满了就会失败。因此，我想在kafka磁盘使用率达到x%时丢弃存储在kafka磁盘上的旧数据（或丢弃数据的副本），从而将磁盘使用率降低到x%以下。我需要修改Kafka的源代码吗？
yrdbyhpb1#
您可以配置 retention.bytes 关于你的主题。如果使用“删除”保留策略，此配置控制分区（由日志段组成）在丢弃旧日志段以释放空间之前可以增长到的最大大小。默认情况下，没有大小限制，只有时间限制。由于此限制是在分区级别强制执行的，因此将其乘以分区数以字节为单位计算主题保留。看到了吗https://kafka.apache.org/documentation/#topicconfigs
retention.bytes
1条答案
按热度按时间yrdbyhpb1#
您可以配置
retention.bytes关于你的主题。如果使用“删除”保留策略，此配置控制分区（由日志段组成）在丢弃旧日志段以释放空间之前可以增长到的最大大小。默认情况下，没有大小限制，只有时间限制。由于此限制是在分区级别强制执行的，因此将其乘以分区数以字节为单位计算主题保留。
看到了吗https://kafka.apache.org/documentation/#topicconfigs