THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
AddPartitionsToTxnRequest => TransactionalId PID Epoch [Topic [Partition]] TransactionalId => string PID => int64 Epoch => int32int16 Topic => string Partition => int32 |
...
Code Block | ||||
---|---|---|---|---|
| ||||
AddOffsetsToTxnRequest => TransactionalId PID Epoch ConsumerGroupID TransactionalId => string PID => int64 Epoch => int32int16 ConsumerGroupID => string |
...
Code Block | ||||
---|---|---|---|---|
| ||||
EndTxnRequest => TransactionalId PID Epoch Command TransactionalId => string PID => int64 Epoch => int32int16 Command => boolean (0 means ABORT, 1 means COMMIT) |
...
Code Block | ||||
---|---|---|---|---|
| ||||
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 | ||||
---|---|---|---|---|
| ||||
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 |
...