1 files changed, 3 insertions, 6 deletions
diff --git a/weed/pb/mq.proto b/weed/pb/mq.proto
index 44291c173..47bd1775e 100644
--- a/weed/pb/mq.proto
+++ b/weed/pb/mq.proto
@@ -10,19 +10,16 @@ option java_outer_classname = "MessagQueueProto";
 
 service SeaweedMessaging {
 
-    rpc FindBroker (FindBrokerRequest) returns (FindBrokerResponse) {
+    rpc FindBrokerLeader (FindBrokerLeader) returns (FindBrokerLeaderResponse) {
     }
 
 }
 
 //////////////////////////////////////////////////
 
-message FindBrokerRequest {
-    string namespace = 1;
-    string topic = 2;
-    int32 parition = 3;
+message FindBrokerLeaderRequest {
 }
 
-message FindBrokerResponse {
+message FindBrokerLeaderResponse {
     string broker = 1;
 }