DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block |
|---|
{
"apiKey": 27,
"type": "request",
"listeners": ["broker"],
"name": "WriteTxnMarkersRequest",
"validVersions": "1-2",
"flexibleVersions": "1+",
"fields": [
{ "name": "Markers", "type": "[]WritableTxnMarker", "versions": "0+",
"about": "The transaction markers to be written.", "fields": [
{ "name": "ProducerId", "type": "int64", "versions": "0+",
"entityType": "producerId", "about": "The current producer ID." },
{ "name": "ProducerEpoch", "type": "int16", "versions": "0+",
"about": "The current epoch associated with the producer ID." },
{ "name": "TransactionResult", "type": "bool", "versions": "0+",
"about": "The result (false = ABORT, true = COMMIT)." },
{ "name": "Topics", "type": "[]WritableTxnMarkerTopic", "versions": "0+",
"about": "Each topic to write markers for.", "fields": [
{ "name": "Name", "type": "string", "versions": "0+",
"entityType": "topicName", "about": "The topic name." },
{ "name": "PartitionIndexes", "type": "[]int32", "versions": "0+",
"about": "Partition indexes to write markers for." }
]},
{ "name": "CoordinatorEpoch", "type": "int32", "versions": "0+",
"about": "Epoch of the transaction state partition hosting this coordinator." },
// --------- NEW FIELD (TV) ADDED BELOW --------
{ "name": "TransactionVersion", "type": "int8", "versions": "2+", "ignorable": true,
"about": "Transaction version: 0/1 = legacy (TV0/TV1), 2 = TV2.", "default": "0" }
]}
]
} |
...