THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
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 | ||
---|---|---|
| ||
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 | ||
---|---|---|
| ||
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 | ||
---|---|---|
| ||
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 |
...