From 00ce031cc87fcb356efcd9722f74b9057b76df98 Mon Sep 17 00:00:00 2001
From: wzl12356 <wzlsuccess@163.com>
Date: Tue, 9 Nov 2021 17:49:51 +0800
Subject: [PATCH] Update WFKafkaClient.cc

---
 src/client/WFKafkaClient.cc | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/client/WFKafkaClient.cc b/src/client/WFKafkaClient.cc
index c979a47b..19d98a20 100644
--- a/src/client/WFKafkaClient.cc
+++ b/src/client/WFKafkaClient.cc
@@ -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();