message.go 263 B

1234567891011
  1. package databus
  2. // Message Data.
  3. type Message struct {
  4. Key string `json:"key"`
  5. Value string `json:"value"`
  6. Topic string `json:"topic"`
  7. Partition int32 `json:"partition"`
  8. Offset int64 `json:"offset"`
  9. Timestamp int64 `json:"timestamp"`
  10. }