if (startOffset >= stopOffset || startOffset >= latestOffset) {
return;
}
int fetchCount = 0;
while (fetchCount == 0) {
<BUG>fetchCount = fetchLogEvents(kafkaConsumer, logFilter, startOffset, stopOffset, maxEvents, callback,

Long.MIN_VALUE);</BUG>
stopOffset = startOffset;
if (stopOffset <= earliestOffset) {

if (startOffset >= stopOffset || startOffset >= latestOffset) {
return;
}
int fetchCount = 0;
while (fetchCount == 0) {
fetchCount = fetchLogEvents(kafkaConsumer, logFilter, startOffset, stopOffset, maxEvents, callback, readRange);
stopOffset = startOffset;
if (stopOffset <= earliestOffset) {
