From 471b4ec5d386bf5ef714eb73c7c93dc6cc493b5c Mon Sep 17 00:00:00 2001 From: mxsm Date: Wed, 18 Dec 2024 13:55:56 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#1845]=F0=9F=90=9BFix=20Query=20assign?= =?UTF-8?q?ment=20from=20broker=20clientId=20not=20correct=F0=9F=9A=91?= =?UTF-8?q?=EF=B8=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rocketmq-client/src/factory/mq_client_instance.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rocketmq-client/src/factory/mq_client_instance.rs b/rocketmq-client/src/factory/mq_client_instance.rs index 4944ac43..da5204f6 100644 --- a/rocketmq-client/src/factory/mq_client_instance.rs +++ b/rocketmq-client/src/factory/mq_client_instance.rs @@ -1196,8 +1196,8 @@ impl MQClientInstance { &broker_addr, topic.clone(), consumer_group.clone(), - strategy_name.clone(), client_id, + strategy_name.clone(), message_model, timeout, )