Versions Compared

Old Version 1

changes.mady.by.user David Arthur

Saved on

compared with

New Version 2

changes.mady.by.user Jay Kreps

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

This would be a two phase change:

  1. First add a new API to move the details of offset storage to the broker.
  2. Improve the way we store the offsets

API

New RequestKeys type "OffsetCommitRequest", key = 6 (or whatever the next one is).

Code Block
OffsetCommitRequest => ConsumerGroup [TopicName [Partition ConsumerGroup Offset [LastOffset]]
  TopicName => string
  Partition => int32
  ConsumerGroup => string
  Offset => int64
  LastOffset => int64

...