message.fbs 647 B

1234567891011121314151617181920212223
  1. table NameValue {
  2. name:string (key);
  3. value:string;
  4. }
  5. table Message {
  6. seq_delta:int32 (id:0);
  7. ts_ms_delta:int32 (id:1);
  8. properties:[NameValue] (id:2);
  9. key:string (id:3); // bytes
  10. data:string (id:4); // bytes
  11. }
  12. table MessageBatch {
  13. producer_id:int32 (id:0);
  14. producer_epoch:int32 (id:1);
  15. segment_id:int32 (id:2);
  16. flags: int32 (id:3);
  17. segment_seq_base:int64 (id:4);
  18. segment_seq_max_delta:int32 (id:5);
  19. ts_ms_base:int64 (id:6);
  20. ts_ms_max_delta:int32 (id:7);
  21. messages: [Message] (id:8);
  22. }