1 files changed, 17 insertions, 9 deletions
diff --git a/weed/pb/message.fbs b/weed/pb/message.fbs
index 8ee6c5b55..170551df7 100644
--- a/weed/pb/message.fbs
+++ b/weed/pb/message.fbs
@@ -3,13 +3,21 @@ table NameValue {
     value:string;
 }
 table Message {
-    producer_id:int32  (id:0);
-    producer_seq:int64 (id:2);
-    segment_id:int32   (id:1);
-    segment_seq:int64  (id:3);
-    event_ts_ns:int64  (id:4);
-    recv_ts_ns:int64   (id:5);
-    properties:[NameValue] (id:6);
-    key:string         (id:7); // bytes
-    data:string        (id:8); // bytes
+    seq_delta:int32         (id:0);
+    ts_ms_delta:int32       (id:1);
+    properties:[NameValue]  (id:2);
+    key:string              (id:3); // bytes
+    data:string             (id:4); // bytes
+}
+
+table MessageBatch {
+    producer_id:int32       (id:0);
+    producer_epoch:int32    (id:1);
+    segment_id:int32        (id:2);
+    flags: int32            (id:3);
+    segment_seq_base:int64          (id:4);
+    segment_seq_max_delta:int32     (id:5);
+    ts_ms_base:int64        (id:6);
+    ts_ms_max_delta:int32         (id:7);
+    messages: [Message]     (id:8);
 }