diff --git a/core/src/main/scala/kafka/log/LogManager.scala b/core/src/main/scala/kafka/log/LogManager.scala index bcd2bb7cb3152..8bd0428eeab94 100644 --- a/core/src/main/scala/kafka/log/LogManager.scala +++ b/core/src/main/scala/kafka/log/LogManager.scala @@ -338,6 +338,7 @@ class LogManager(val logDirs: Array[File], diff -= segment.size true } else { + diff = 0 false } }