import static java.util.concurrent.TimeUnit.*;
import static org.graylog2.plugin.Tools.bytesToHex;
@Singleton
public class KafkaJournal extends AbstractIdleService implements Journal {
private static final Logger LOG = LoggerFactory.getLogger(KafkaJournal.class);
<BUG>public static final long DEFAULT_COMMITTED_OFFSET = Long.MIN_VALUE;
private static final Time JODA_TIME = new Time() {</BUG>
@Override
public long milliseconds() {
return DateTimeUtils.currentTimeMillis();

import static java.util.concurrent.TimeUnit.*;
import static org.graylog2.plugin.Tools.bytesToHex;
@Singleton
public class KafkaJournal extends AbstractIdleService implements Journal {
private static final Logger LOG = LoggerFactory.getLogger(KafkaJournal.class);
public static final long DEFAULT_COMMITTED_OFFSET = Long.MIN_VALUE;
public static final int NOTIFY_ON_UTILIZATION_PERCENTAGE = 95;
private static final Time JODA_TIME = new Time() {
@Override
public long milliseconds() {
return DateTimeUtils.currentTimeMillis();
