return;
}
int partition = partitioner.partition(loggingContext.getLogPartition(), -1);
callback.init();
KafkaConsumer kafkaConsumer = new KafkaConsumer(seedBrokers, topic, partition, KAFKA_FETCH_TIMEOUT_MS);
<BUG>long fromTimeMs = Long.MIN_VALUE;</BUG>
try {
<BUG>if (fromOffset.getKafkaOffset() == LogOffset.INVALID_KAFKA_OFFSET) {

fromOffset =
new LogOffset(kafkaConsumer.fetchOffsetBefore(fromOffset.getTime()), fromOffset.getTime());
fromTimeMs = fromOffset.getTime();</BUG>
}

return;
}
int partition = partitioner.partition(loggingContext.getLogPartition(), -1);
callback.init();
KafkaConsumer kafkaConsumer = new KafkaConsumer(seedBrokers, topic, partition, KAFKA_FETCH_TIMEOUT_MS);
try {
if (readRange.getKafkaOffset() == LogOffset.INVALID_KAFKA_OFFSET) {
readRange = new ReadRange(readRange.getFromMillis(), readRange.getToMillis(),
kafkaConsumer.fetchOffsetBefore(readRange.getFromMillis()));
}
