total,
NANOSECONDS.toSeconds(ctx.stop()));
return total;
}
private int cleanupExpiredSegments(final Log kafkaLog) {
<BUG>if (kafkaLog.size() == 0 && kafkaLog.numberOfSegments() < 1) {
return 0;</BUG>
}
<BUG>return kafkaLog.deleteOldSegments(new AbstractFunction1<LogSegment, Object>() {
</BUG>
@Override

total,
NANOSECONDS.toSeconds(ctx.stop()));
return total;
}
private int cleanupExpiredSegments(final Log kafkaLog) {
if (kafkaLog.size() == 0 && kafkaLog.numberOfSegments() < 1) {
KafkaJournal.this.purgedSegmentsInLastRetention.set(0);
return 0;
}
int deletedSegments = kafkaLog.deleteOldSegments(new AbstractFunction1<LogSegment, Object>() {
@Override
