THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Ok
InvalidProducerEpoch
InvalidPidMapping
CoordinatorNotAvailable
NotCoordinatorForTransactionalId
InvalidTxnRequest
...
WriteTxnMarkersRequest/Response
Sent by transaction coordinator to broker to commit the transaction. Request handling details can be found here.
Code Block | ||||
---|---|---|---|---|
| ||||
WriteTxnMarkerRequestWriteTxnMarkersRequest => CoordinatorEpoch [PID Epoch Marker CoordinatorEpoch [Topic [PartitionPartitions]]] PIDCoordinatorEpoch => int64int32 EpochPID => int16int64 CoordinatorEpochEpoch => int32int16 Marker => int8 (0 = COMMIT, 1 = ABORT) Topic => string Partition => int32 |
...