logRetentionCleaner = new LogRetentionCleaner();
} catch (KafkaException e) {
LOG.error("Unable to start logmanager.", e);
throw new RuntimeException(e);
}
<BUG>}
private void setupKafkaLogMetrics(final MetricRegistry metricRegistry) {</BUG>
metricRegistry.register(name(KafkaJournal.class, "size"), new Gauge<Long>() {
@Override
public Long getValue() {

logRetentionCleaner = new LogRetentionCleaner();
} catch (KafkaException e) {
LOG.error("Unable to start logmanager.", e);
throw new RuntimeException(e);
}
}
public int getPurgedSegmentsInLastRetention() {
return purgedSegmentsInLastRetention.get();
}
private void setupKafkaLogMetrics(final MetricRegistry metricRegistry) {
metricRegistry.register(name(KafkaJournal.class, "size"), new Gauge<Long>() {
@Override
public Long getValue() {
