From fc28fddba8ebeb775a607b31493a22e36e62ec00 Mon Sep 17 00:00:00 2001
From: wzl12356 <wzlsuccess@163.com>
Date: Fri, 18 Mar 2022 19:32:29 +0800
Subject: [PATCH] kafka: fix endless loop when fetch message from empty topic
 partition

---
 src/factory/KafkaTaskImpl.cc | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/factory/KafkaTaskImpl.cc b/src/factory/KafkaTaskImpl.cc
index 1263c181..9843c74a 100644
--- a/src/factory/KafkaTaskImpl.cc
+++ b/src/factory/KafkaTaskImpl.cc
@@ -516,7 +516,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);