topic, partition), e);
}
}
}
@Override
<BUG>public void getLogPrev(LoggingContext loggingContext, LogOffset fromOffset, int maxEvents,
</BUG>
Filter filter, Callback callback) {
<BUG>if (fromOffset.getKafkaOffset() == LogOffset.INVALID_KAFKA_OFFSET) {

fromOffset = LogOffset.LATEST_OFFSET;
}</BUG>
int partition = partitioner.partition(loggingContext.getLogPartition(), -1);

topic, partition), e);
}
}
}
@Override
public void getLogPrev(LoggingContext loggingContext, ReadRange readRange, int maxEvents,
Filter filter, Callback callback) {
if (readRange.getKafkaOffset() == LogOffset.INVALID_KAFKA_OFFSET) {
readRange = ReadRange.LATEST;
}
int partition = partitioner.partition(loggingContext.getLogPartition(), -1);
