From 2035e6fc5d970bd6f4369c55103855c1167df7bd Mon Sep 17 00:00:00 2001
From: dinglei <libya_003@163.com>
Date: Fri, 14 Jan 2022 11:06:36 +0800
Subject: [PATCH] fix build error in RIP-28 at getmQclientFactory (#3753)

---
 .../apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java b/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
index 392b306734..d9335ebec5 100644
--- a/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
+++ b/test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
@@ -242,7 +242,7 @@ public class BenchLmqStore {
         Map<String, Long> offsetMap = new ConcurrentHashMap<>();
         String statKey = "benchOffset";
         TopicRouteData topicRouteData = defaultMQPullConsumers[0].getDefaultMQPullConsumerImpl().
-                getRebalanceImpl().getMqClientFactory().getMQClientAPIImpl().
+                getRebalanceImpl().getmQClientFactory().getMQClientAPIImpl().
                 getTopicRouteInfoFromNameServer(lmqTopic, 3000);
         HashMap<Long, String> brokerMap = topicRouteData.getBrokerDatas().get(0).getBrokerAddrs();
         if (brokerMap == null || brokerMap.isEmpty()) {
@@ -277,7 +277,7 @@ public class BenchLmqStore {
                             defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     .getMQClientAPIImpl().updateConsumerOffset(brokerAddress, updateHeader, 1000);
                             QueryConsumerOffsetRequestHeader queryHeader = new QueryConsumerOffsetRequestHeader();
                             queryHeader.setTopic(lmq);
@@ -286,7 +286,7 @@ public class BenchLmqStore {
                             long newOffset2 = defaultMQPullConsumer
                                     .getDefaultMQPullConsumerImpl()
                                     .getRebalanceImpl()
-                                    .getMqClientFactory()
+                                    .getmQClientFactory()
                                     .getMQClientAPIImpl()
                                     .queryConsumerOffset(brokerAddress, queryHeader, 1000);
                             offsetMap.put(lmq, newOffset2);