Prüft die behauptete geordnete read_committed-Datensatzsicht eines vollständigen...

{ "body": { "artifact": { "batches": [ { "kind": "txn", "producer": 1, "records": 1 }, { "kind": "txn", "producer": 2, "records": 2 }, { "kind": "commit", "producer": 1, "records": 1 }, { "kind": "plain", "producer": 0, "records": 1 }, { "kind": "abort", "producer": 2, "records": 1 } ], "claimed_visible_offsets": [ 0, 4 ], "claims": { "aborted_records_filtered": 2, "aborted_transactions": 1, "active_transactions": 0, "barrier_records_withheld": 0, "batches": 5, "committed_transactions": 1, "control_records_below_watermark": 2, "last_stable_offset": 6, "replicated_records": 6, "visible_records": 2 }, "complete_uncompacted_prefix": true, "fetch_offset": 0, "high_watermark": 6 } }, "bodyType": "json", "method": "POST", "type": "http" }

{ "example": { "billable": true, "findings": [ { "confidence": 100, "evidence": [], "limits": [ "ApacheKafka4.0.0 ProducerStateManager.firstUnstableOffset/onHighWatermarkUpdated and CompletedFetch.nextFetchedRecord/isBatchAborted: read_committed excludes offsets>=LSO, filters aborted transactional data, suppresses controlrecords; abortmarker ends that producer abortion so later transactions reusingPID remain eligible. Own prefix/transaction matching and record visibility, no Kafka/SQL/MVCC SDK.", "One complete uncompacted normalized recordformat2 partition log fromoffset0, no retention/gaps/compression/CRC/leader-epoch validation.64batches;data1..64records,controlone;offsets derived cumulatively, total<=4096. Highwatermark is replicated EXCLUSIVE boundary and must coincide with batchend; sourcefetchOffset inside0..logend. Labels are anonymous producer equality classes, no topic/key/value/identity contents.", "Only markers below highwatermark complete transactions. Unreplicated commit/abort remains an unstable open prefix until replicated. Independent concurrently open producers permitted; per-producer transactions sequential with closingmarker; orphancontrol belowwatermark wholeunknown. No newtransaction epoch fencing, ongoing coordinator/replication process or actualbroker fetch is claimed.", "LSO=min(highwatermark,earliestopen transactionstart). Its globalprefixbarrier withholds even later committed or plainrecords; abortfilter then applies only belowLSO and at/after fetchOffset. Controlrecords neverreturned. Contexttransaction/control counts reflect whole supplied replicatedprefix, not necessarily fetchedsuffix. Only orderedexact visible-offset claims checked, missing/extra/duplicate/fractional claims disagree.", "Only bounded counts/bools, includingLSO as countofrecords sincezero. No raw producerIDs, recordoffset list, records/keys/values, callerclaims or exceptionecho. Phone-shaped producerlabels remain internal. No actualdatabase/broker visibility/security/durability promise or network calls." ], "module": "kafka-committed-prefix-abort-visibility-claims", "state": "not_observed", "value": { "aborted_records_filtered": 2, "aborted_transactions": 1, "active_transactions": 0, "barrier_records_withheld": 0, "batches": 5, "claim_mismatches": 0, "claims_match": true, "committed_transactions": 1, "control_records_below_watermark": 2, "last_stable_offset": 6, "replicated_records": 6, "visibility_claim_matches": true, "visible_records": 2 }, "warnings": [] } ], "known_count": 1, "scope": { "contact_values_returned": false, "network": false, "supplied_artifact_only": true }, "warnings": [] }, "type": "json" }