reset redirectedClusterURI

BewareMyPower · BewareMyPower · commit 696d616491f6 · 2026-03-13T12:48:15.000+08:00
diff --git a/lib/ConsumerImpl.cc b/lib/ConsumerImpl.cc
@@ -1145,6 +1145,7 @@ void ConsumerImpl::onClusterSwitching() {
         seekStatus_ = SeekStatus::NOT_STARTED;
         lastSeekArg_.reset();
     }
+    setRedirectedClusterURI("");
     ackGroupingTrackerPtr_->flushAndClean();
 }
 

Original file line number	Diff line number	Diff line change
`@@ -1145,6 +1145,7 @@ void ConsumerImpl::onClusterSwitching() {`
`1145`	`1145`	`seekStatus_ = SeekStatus::NOT_STARTED;`
`1146`	`1146`	`lastSeekArg_.reset();`
`1147`	`1147`	`}`
	`1148`	`+ setRedirectedClusterURI("");`
`1148`	`1149`	`ackGroupingTrackerPtr_->flushAndClean();`
`1149`	`1150`	`}`
`1150`	`1151`