return true;
} else {
return false;
}
}
<BUG>});
}</BUG>
private int cleanupSegmentsToRemoveCommitted(Log kafkaLog) {
if (kafkaLog.numberOfSegments() <= 1) {
loggerForCleaner.debug(

return true;
} else {
return false;
}
}
});
KafkaJournal.this.purgedSegmentsInLastRetention.set(deletedSegments);
return deletedSegments;
}
private int cleanupSegmentsToRemoveCommitted(Log kafkaLog) {
if (kafkaLog.numberOfSegments() <= 1) {
loggerForCleaner.debug(
