GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-20 06:11:21 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka: fix endless loop when fetch message from empty topic partition

Browse Source
This commit is contained in:
wzl12356
2022-03-18 19:32:29 +08:00
parent 3b3d9ae073
commit fc28fddba8
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/factory/KafkaTaskImpl.cc
+1 -1
View File
@@ -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);