diff --git a/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs b/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs
index 3065b344..7033baa9 100644
--- a/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs
+++ b/rocketmq-client/src/consumer/allocate_message_queue_strategy.rs
@@ -22,8 +22,8 @@ use crate::Result;
 pub trait AllocateMessageQueueStrategy: Send + Sync {
     fn allocate(
         &self,
-        consumer_group: &str,
-        current_cid: &str,
+        consumer_group: &CheetahString,
+        current_cid: &CheetahString,
         mq_all: &[MessageQueue],
         cid_all: &[CheetahString],
     ) -> Result<Vec<MessageQueue>>;
diff --git a/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs b/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs
index ce0b2ed4..432be955 100644
--- a/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs
+++ b/rocketmq-client/src/consumer/rebalance_strategy/allocate_message_queue_averagely.rs
@@ -26,8 +26,8 @@ pub struct AllocateMessageQueueAveragely;
 impl AllocateMessageQueueStrategy for AllocateMessageQueueAveragely {
     fn allocate(
         &self,
-        consumer_group: &str,
-        current_cid: &str,
+        consumer_group: &CheetahString,
+        current_cid: &CheetahString,
         mq_all: &[MessageQueue],
         cid_all: &[CheetahString],
     ) -> Result<Vec<MessageQueue>> {