for (LogEvent logLine : logEvents) {
if (!contextFilter.match(logLine.getLoggingEvent())) {
continue;
}
if (logLine.getOffset().getKafkaOffset() >= startOffset &&
<BUG>logLine.getOffset().getKafkaOffset() < fromOffset.getKafkaOffset()) {
</BUG>
if (++count > maxEvents) {
break;
}

for (LogEvent logLine : logEvents) {
if (!contextFilter.match(logLine.getLoggingEvent())) {
continue;
}
if (logLine.getOffset().getKafkaOffset() >= startOffset &&
logLine.getOffset().getKafkaOffset() < readRange.getKafkaOffset()) {
if (++count > maxEvents) {
break;
}
