GithubStar/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-10-29 03:27:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update WFKafkaClient.cc

Browse Source
This commit is contained in:
wzl12356
2021-11-09 17:49:51 +08:00
committed by GitHub
parent 75eb145c9e
commit 00ce031cc8
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/WFKafkaClient.cc
+3 -2
View File
@@ -347,8 +347,9 @@ private:
int ComplexKafkaTask::get_node_id(const KafkaToppar *toppar)
{
if (toppar->get_preferred_read_replica() >= 0)
return toppar->get_preferred_read_replica();
int preferred_read_replica = toppar->get_preferred_read_replica();
if (preferred_read_replica >= 0)
return preferred_read_replica;
bool flag = false;
this->client_meta_list.rewind();