Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Consistent ordering of leader epoch field

...

Code Block
linenumberstrue
FetchRequest => MaxWaitTime ReplicaId MinBytes IsolationLevel FetchSessionId FetchSessionEpoch [Topics] [RemovedTopics]
  MaxWaitTime => INT32
  ReplicaId => INT32
  MinBytes => INT32
  IsolationLevel => INT8
  FetchSessionId => INT32
  FetchSessionEpoch => INT32
  Topics => TopicName Partitions
  	TopicName => STRING
  	Partitions => [Partition FetchOffset StartOffset LeaderEpoch MaxBytes]
  		Partition => INT32
  		FetchOffsetCurrentLeaderEpoch => INT64INT32   // New
  		StartOffsetFetchOffset => INT64
  		CurrentLeaderEpochStartOffset => INT32   // NewINT64
  		MaxBytes => INT32
  RemovedTopics => RemovedTopicName [RemovedPartition]
  	RemovedTopicName => STRING
  	RemovedPartition => INT32

...

Code Block
linenumberstrue
OffsetCommitRequest => GroupId Generation MemberId [TopicName [Partition Offset Timestamp LastLeaderEpoch Metadata]]
  GroupId => STRING
  Generation => INT32
  MemberId => STRING
  RetentionTime => INT64
  TopicName => STRING
  Partition => INT32
  Offset => INT64
  LeaderEpoch => INT32  // New
  Offset => INT64
  Metadata => STRING

OffsetFetch

...

Code Block
linenumberstrue
OffsetFetchResponse => [TopicName [Partition Offset Timestamp LastLeaderEpoch Metadata ErrorCode]]
  TopicName => STRING
  Partition => INT32
  Offset => INT64
  LeaderEpoch => INT32  // New
  Offset => INT64
  Metadata => STRING
  ErrorCode => INT16

...

Code Block
linenumberstrue
ListOffsetResponse => [TopicName [Partition Offset LeaderEpoch Timestamp ErrorCode]]
  TopicName => STRING
  Partition => INT32
  Offset => INT64
  LeaderEpoch => INT32  // New
  Offset => INT64
  Timestamp => INT64
  ErrorCode => INT16

...

Code Block
Offset Commit Value Schema (Version: 3) =>
  OffsetLeaderEpoch => INT64 INT32 // New
  LeaderEpochOffset => INT32 // NewINT64
  Metadata => STRING
  CommitTimestamp => INT64

...