Skip to main content

transaction_marker_materialization_decision

Function transaction_marker_materialization_decision 

Source
pub fn transaction_marker_materialization_decision(
    request: TransactionMarkerRequest,
    current: TransactionMarkerPartitionState,
) -> TransactionMarkerMaterializationDecision
Expand description

Fence a transaction marker against the partition’s latest producer and coordinator generations, suppress an exact completed retry, and publish offsets only for a pending commit on __consumer_offsets.