From 0ca68a2a6d87786dbebe87fbd4b786b3318c1dcb Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Sun, 1 Mar 2020 22:13:15 -0800
Subject: [PATCH] WIP

---
 weed/pb/queue.proto | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/weed/pb/queue.proto b/weed/pb/queue.proto
index e212991d3..39b6ee05a 100644
--- a/weed/pb/queue.proto
+++ b/weed/pb/queue.proto
@@ -29,7 +29,8 @@ service SeaweedQueue {
 message WriteMessageRequest {
     string topic = 1;
     int64 event_ns = 2;
-    bytes data = 3;
+    bytes partition_key = 3;
+    bytes data = 4;
 }
 
 message WriteMessageResponse {
@@ -51,6 +52,7 @@ message ReadMessageResponse {
 message ConfigureTopicRequest {
     string topic = 1;
     int64 ttl_seconds = 2;
+    int32 partition_count = 3;
 }
 message ConfigureTopicResponse {
     string error = 1;