public class ThrottleStateUpdaterThread extends Periodical {
private static final Logger log = LoggerFactory.getLogger(ThrottleStateUpdaterThread.class);
private final KafkaJournal journal;
private final ProcessBuffer processBuffer;
private final EventBus eventBus;
<BUG>private final Size retentionSize;
private boolean firstRun = true;</BUG>
private long logStartOffset;
private long logEndOffset;
private long previousLogEndOffset;

public class ThrottleStateUpdaterThread extends Periodical {
private static final Logger log = LoggerFactory.getLogger(ThrottleStateUpdaterThread.class);
private final KafkaJournal journal;
private final ProcessBuffer processBuffer;
private final EventBus eventBus;
private final Size retentionSize;
private final NotificationService notificationService;
private final ServerStatus serverStatus;
private boolean firstRun = true;
private long logStartOffset;
private long logEndOffset;
private long previousLogEndOffset;
