update broker api

wenweihu86 · Jun 24, 2017 · 3d12a35 · 3d12a35
1 parent 7f3c8cb
commit 3d12a35
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 157 deletions.
diff --git a/distmq-client/src/main/java/com/github/wenweihu86/distmq/client/api/BrokerMessage.java b/distmq-client/src/main/java/com/github/wenweihu86/distmq/client/api/BrokerMessage.java
diff --git a/distmq-client/src/main/java/com/github/wenweihu86/distmq/client/api/broker.proto b/distmq-client/src/main/java/com/github/wenweihu86/distmq/client/api/broker.proto
@@ -35,8 +35,7 @@ message PullMessageRequest {
     string topic = 1;
     int32 queue = 2;
     int64 offset = 3;
-    string consumer_group = 4;
-    int32 message_count = 5;
+    int32 message_count = 4;
 }
 
 message PullMessageResponse {