private final Filter logFilter;
private final LoggingEventSerializer serializer;
private final long stopOffset;
private final int maxEvents;
private final Callback callback;
<BUG>private final long fromTimeMs;
private long lastOffset = -1;
</BUG>
private int count = 0;
private KafkaCallback(Filter logFilter, LoggingEventSerializer serializer, long stopOffset, int maxEvents,

private final Filter logFilter;
private final LoggingEventSerializer serializer;
private final long stopOffset;
private final int maxEvents;
private final Callback callback;
private final long fromTimeMs;
private LogOffset firstOffset;
private LogOffset lastOffset;
private int count = 0;
private KafkaCallback(Filter logFilter, LoggingEventSerializer serializer, long stopOffset, int maxEvents,
