THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 LeaderEpoch Metadata]] TopicName => STRING Partition => INT32 Offset => INT64 LeaderEpoch => INT32 // New Metadata => STRING |
...