1 files changed, 3 insertions, 3 deletions
diff --git a/weed/pb/mq.proto b/weed/pb/mq.proto
index cc4f962f2..6bff064f8 100644
--- a/weed/pb/mq.proto
+++ b/weed/pb/mq.proto
@@ -21,7 +21,7 @@ service SeaweedMessaging {
     }
 
     // control plane for balancer
-    rpc ConnectToBalancer (stream ConnectToBalancerRequest) returns (stream ConnectToBalancerResponse) {
+    rpc ConnectToPubCoordinator (stream ConnectToPubCoordinatorRequest) returns (stream ConnectToPubCoordinatorResponse) {
     }
     rpc DoConfigureTopic (DoConfigureTopicRequest) returns (DoConfigureTopicResponse) {
     }
@@ -122,7 +122,7 @@ message TopicPartitionStats {
 }
 
 
-message ConnectToBalancerRequest {
+message ConnectToPubCoordinatorRequest {
     message InitMessage {
         string broker = 1;
     }
@@ -131,7 +131,7 @@ message ConnectToBalancerRequest {
         BrokerStats stats = 2;
     }
 }
-message ConnectToBalancerResponse {
+message ConnectToPubCoordinatorResponse {
 }
 //////////////////////////////////////////////////
 message ConfigureTopicRequest {