Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: Change epoch from int32 -> int16 in the protocol

...

Code Block
languagetext
titleAddPartitionsToTxnRequest
AddPartitionsToTxnRequest => TransactionalId PID Epoch [Topic [Partition]]
 TransactionalId => string
 PID => int64
 Epoch => int32int16
 Topic => string
 Partition => int32

...

Code Block
languagetext
titleAddOffsetsToTxnRequest
AddOffsetsToTxnRequest => TransactionalId PID Epoch ConsumerGroupID
 TransactionalId => string
 PID => int64
 Epoch => int32int16
 ConsumerGroupID => string

...

Code Block
languagetext
titleEndTxnRequest
EndTxnRequest => TransactionalId PID Epoch Command
 TransactionalId => string
 PID => int64
 Epoch => int32int16
 Command => boolean (0 means ABORT, 1 means COMMIT)

...

Code Block
languagetext
titleWriteTxnMarkerRequest
WriteTxnMarkerRequest => PID Epoch Marker CoordinatorEpoch [Topic [Partition]]
 PID => int64
 Epoch => int32int16
 CoordinatorEpoch => int32
 Marker => int8 (0 = COMMIT, 1 = ABORT)
 Topic => string
 Partition => int32

...

Code Block
languagetext
titleTxnOffsetCommitRequest
TxnOffsetCommitRequest   => ConsumerGroupID
                           PID
                           Epoch
                           RetentionTime
                           OffsetAndMetadata
 ConsumerGroupID => string
 PID => int64
 Epoch => int32int16
 RetentionTime => int64
 OffsetAndMetadata => [TopicName [Partition Offset Metadata]]
   TopicName => string
   Partition => int32
   Offset => int64
   Metadata => string

...