THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
OffsetCommitRequest => GroupId Generation MemberId [TopicName [Partition Offset Timestamp LastLeaderEpochLeaderEpoch Metadata]] GroupId => STRING Generation => INT32 MemberId => STRING RetentionTime => INT64 TopicName => STRING Partition => INT32 LeaderEpoch => INT32 // New Offset => INT64 Metadata => STRING |
TxnOffsetCommit
Similarly, we need to add the leader epoch to the TxnOffsetCommit API, which is used by transactional producers.
| Code Block |
|---|
TxnOffsetCommitRequest => TransactionalId GroupId ProducerId ProducerEpoch Topics
GroupId => STRING
Generation => INT32
MemberId => STRING
RetentionTime => INT64
Topics => [TopicName [Partition Offset Timestamp LeaderEpoch Metadata]]
TopicName => STRING
Partition => INT32
LeaderEpoch => INT32 // New
Offset => INT64
Metadata => STRING |
OffsetFetch
...