diff --git a/src/factory/KafkaTaskImpl.cc b/src/factory/KafkaTaskImpl.cc index 04c28091..0f1dfa04 100644 --- a/src/factory/KafkaTaskImpl.cc +++ b/src/factory/KafkaTaskImpl.cc @@ -515,7 +515,7 @@ bool __ComplexKafkaTask::process_fetch() while ((toppar = this->get_resp()->get_toppar_list()->get_next()) != NULL) { if (toppar->get_error() == KAFKA_OFFSET_OUT_OF_RANGE && - toppar->get_offset() >= 0) + toppar->get_high_watermark() - toppar->get_low_watermark() > 0) { toppar->set_offset(KAFKA_OFFSET_OVERFLOW); toppar->set_low_watermark(KAFKA_OFFSET_UNINIT);