Filter contextFilter = LoggingContextHelper.createFilter(loggingContext);
callback.init();
try {
int count = 0;
for (LogEvent logLine : logEvents) {
<BUG>if (logLine.getOffset().getKafkaOffset() >= fromOffset.getKafkaOffset()) {
</BUG>
if (!contextFilter.match(logLine.getLoggingEvent())) {
continue;
}

Filter contextFilter = LoggingContextHelper.createFilter(loggingContext);
callback.init();
try {
int count = 0;
for (LogEvent logLine : logEvents) {
if (logLine.getOffset().getKafkaOffset() >= readRange.getKafkaOffset()) {
if (!contextFilter.match(logLine.getLoggingEvent())) {
continue;
}
