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

Merge pull request #812 from wzl12356/windows

Browse Source 
kafka: fix endless loop when fetch message from empty topic partition (Windows)
This commit is contained in:
xiehan
2022-03-18 19:38:54 +08:00
committed by GitHub
parent 8bc0dd490c 4254ffa34f
commit e4190dfcb2
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
@@ -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);