1 files changed, 2 insertions, 0 deletions
diff --git a/weed/pb/mq.proto b/weed/pb/mq.proto
index 424dc4b4f..d3e7e5ef2 100644
--- a/weed/pb/mq.proto
+++ b/weed/pb/mq.proto
@@ -165,6 +165,7 @@ message SubscribeRequest {
     message Consumer {
         string consumer_group = 1;
         string consumer_id = 2;
+        string client_id = 3;
     }
     message Cursor {
         Topic topic = 1;
@@ -173,6 +174,7 @@ message SubscribeRequest {
             int64 start_offset = 3;
             int64 start_timestamp_ns = 4;
         }
+        string filter = 5;
     }
     Consumer consumer = 1;
     Cursor cursor = 2;