我有一个关于每个kafka代理使用多个磁盘的问题。假设一个kafka代理有3个磁盘与之关联。
i） 磁盘-1在5天内已满
ii）disk-2在未来3天内的使用率接近40%。
现在如果 log.retention.hours = 168 （7天）已完成，那么假设磁盘1中的数据已被删除，因此磁盘1再次可用，磁盘2已使用40%
现在，Kafka会再次使用磁盘1进行新的写入，还是只写入新磁盘，即磁盘2、磁盘3等等？
基本上，我的问题是，如果在kafka中的最大保留天数之后，由于消息删除，旧磁盘中有足够的可用空间，kafka会再次写入旧磁盘吗？
1条答案
按热度按时间8e2ybdfx1#
创建分区时，作为副本的每个代理都将选择一个日志目录来放置该分区的数据。在代理上，特定分区的数据只存储在选定的日志目录中。
日志目录在代理配置中通过
log.dirs设置。如果您有多个日志目录，则在创建分区时，会选取分区数最少的日志目录。
当向分区生成消息时，数据进入该分区所在的日志目录。
简言之，你的具体问题的答案是“视情况而定”，但希望我已经描述了足够清楚的过程，让你找出你的确切情况的答案。