THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
OffsetCommitRequest => GroupId Generation MemberId [TopicName [Partition Offset Timestamp LeaderEpoch Metadata]] GroupId => STRING Generation => INT32 MemberId => STRING RetentionTime => INT64 TopicName => STRING Partition => INT32 Offset => INT64 LeaderEpoch => INT32 // New Offset => INT64 Metadata => STRING |
TxnOffsetCommit
...
| 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
LeaderEpochOffset => INT32INT64
// New
LeaderEpoch => INT32 Offset =>// INT64New
Metadata => STRING |
OffsetFetch
...
| Code Block | ||
|---|---|---|
| ||
OffsetFetchResponse => ThrottleTimeMs Topics ErrorCode ThrottleTimeMs => INT64 Topics => [TopicName [Partition LeaderEpoch Offset Timestamp LastLeaderEpoch Metadata ErrorCode]] TopicName => STRING Partition => INT32 LeaderEpoch Offset => INT32INT64 LeaderEpoch => INT32 // New Offset Metadata => INT64STRING MetadataErrorCode => STRINGINT16 ErrorCode => INT16 |
ListOffsets
...
| Code Block | ||
|---|---|---|
| ||
ListOffsetResponse => ThrottleTimeMs Topics ThrottleTimeMs => INT64 Topics => [TopicName [Partition Offset LeaderEpoch Timestamp ErrorCode]] TopicName => STRING Partition => INT32 LeaderEpochErrorCode => INT32 INT16 // New OffsetTimestamp => INT64 TimestampOffset => INT64 ErrorCode LeaderEpoch => INT16 INT32 // New |
As with the Fetch and OffsetForLeaderEpoch APIs, the response will support the FENCED_LEADER_EPOCH and UNKNOWN_LEADER_EPOCH error codes.
...
| Code Block |
|---|
Offset Commit Value Schema (Version: 3) => Offset => INT64 LeaderEpoch => INT32 // New Offset => INT64 Metadata => STRING CommitTimestamp => INT64 |
...