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, )