unused

7 months ago · 3b7f24b1fc
2 changed files with 400 additions and 500 deletions
--- a/weed/pb/mq.proto
+++ b/weed/pb/mq.proto
@ -177,13 +177,8 @@ message SubscriberToSubCoordinatorRequest {
        // Default is 10 seconds.
        int32 rebalance_seconds = 5;
    }
-    message AckMessage {
-        Partition partition = 1;
-        int64 ts_ns = 2;
-    }
    oneof message {
        InitMessage init = 1;
-        AckMessage ack = 2;
    }
 }
 message SubscriberToSubCoordinatorResponse {
--- a/weed/pb/mq_pb/mq.pb.go
+++ b/weed/pb/mq_pb/mq.pb.go