{"uid":"cap_5HTxCwKSppEXLOTYfmHlL","slug":"kafka-committed-prefix-abort-visibility-validator-30349b2d","name":"Kafka Committed Prefix Abort Visibility Validator","description":"Prüft die behauptete geordnete read_committed-Datensatzsicht eines vollständigen synthetischen Kafka-Partitionspräfixes, einschließlich globaler LSO-Barriere, Abbrüchen, Kontrollmarkern und späterer Producer-Wiederverwendung, bevor ein Agent ein Fetch-Modell übernimmt.","url":"https://detect.halowerk.com/v1/F-B-NIGHT-KAFKA_COMMITTED_PREFIX_VISIBILITY/kafka-committed-prefix-abort-visibility-claims?utm_source=zero.xyz","method":"POST","headers":{},"bodySchema":{"type":"object","properties":{"artifact":{"type":"object","required":["complete_uncompacted_prefix","batches","high_watermark","fetch_offset","claimed_visible_offsets","claims"],"properties":{"claims":{"type":"object","required":["batches","replicated_records","last_stable_offset","active_transactions","committed_transactions","aborted_transactions","control_records_below_watermark","visible_records","aborted_records_filtered","barrier_records_withheld"],"properties":{"batches":{"type":"number"},"visible_records":{"type":"number"},"last_stable_offset":{"type":"number"},"replicated_records":{"type":"number"},"active_transactions":{"type":"number"},"aborted_transactions":{"type":"number"},"committed_transactions":{"type":"number"},"aborted_records_filtered":{"type":"number"},"barrier_records_withheld":{"type":"number"},"control_records_below_watermark":{"type":"number"}},"additionalProperties":false},"batches":{"type":"array","items":{"type":"object","required":["kind","producer","records"],"properties":{"kind":{"enum":["plain","txn","commit","abort"]},"records":{"type":"integer","maximum":64,"minimum":1},"producer":{"type":"integer","maximum":4294967295,"minimum":0}},"additionalProperties":false},"maxItems":64},"fetch_offset":{"type":"integer","maximum":4096,"minimum":0},"high_watermark":{"type":"integer","maximum":4096,"minimum":0},"claimed_visible_offsets":{"type":"array","items":{"type":"number"},"maxItems":4096},"complete_uncompacted_prefix":{"type":"boolean"}},"additionalProperties":false}}},"responseSchema":null,"example":null,"exampleRequest":null,"tags":["x402"],"displayCostAmount":"0.003","displayCostAsset":"USDC","priceDynamic":false,"priceHint":null,"priceStatus":"priced","priceSource":"probe","requiresHandshake":false,"reviewCount":0,"rating":{"score":"0.00","successRate":"0.00","reviews":0,"stars":null,"state":"unrated"},"availabilityStatus":"unknown","priceObserved":null,"sessionDeposit":null,"pricing":{"kind":"static","summary":"$0.003/call","primary":{"kind":"static","protocol":"x402","network":"base","amountUsd":"0.003","per":"call","confidence":"exact"},"accepted":[{"kind":"static","protocol":"x402","network":"base","amountUsd":"0.003","per":"call","confidence":"exact"}]},"paymentMethods":[{"uid":"pm_U3t2a9OpnY4OqlE-yjWAM","protocol":"x402","methodType":"crypto","chain":"base","mode":"charge","costAmount":"0.003","costPer":"request","priority":0,"asset":"0x833589fCD6eDb6E08f4c7C32D4f71b54bdA02913","unit":"request","depositMicros":null,"planRef":null}],"brandName":null,"brandSlug":null,"brandBaseUrl":null,"brandDocsUrl":null,"whatItDoes":"Validates claimed read_committed visibility of a complete synthetic Kafka partition prefix, checking LSO barrier, aborts, control markers, and producer reuse consistency.","exampleAgentPrompt":"Before my agent adopts this fetch model, can you verify this Kafka partition prefix snapshot — it has 12 batches, high watermark at 500, fetch offset at 0, claims 8 visible records, 2 aborted transactions, LSO at 480, 1 active transaction, 3 control records below watermark, and here are the claimed visible offsets and batch details?","exampleUseCases":[{"title":"Pre-adoption fetch model audit","prompt":"I'm about to let an agent take over a Kafka fetch model — can you validate this complete partition prefix snapshot first? It has 20 batches, high watermark 1024, fetch offset 0, LSO 1000, 2 committed transactions, 1 aborted transaction, 5 control records below watermark, and 15 claimed visible offsets. I want to confirm the read_committed visibility claims are accurate before proceeding."},{"title":"Abort filtering correctness check","prompt":"Can you check whether this Kafka prefix correctly withholds aborted records from the consumer view? I have 8 batches including 2 txn batches that were aborted, fetch offset 50, high watermark 300, LSO 290, and the claimed visible offsets list excludes those aborted ranges — I need to verify the abort filtering is right."},{"title":"Producer reuse and LSO barrier validation","prompt":"This Kafka partition log has a producer that was reused across multiple transaction epochs — can you audit whether the claimed read_committed visibility is consistent after that reuse? There are 15 batches, high watermark 800, LSO 750, 3 committed transactions, 1 active transaction, and 2 control marker records. I need to confirm the LSO barrier is correctly enforced."}],"resultDescription":"Returns a structured validation verdict on whether the claimed read_committed visibility of the Kafka partition prefix is correct, including checks on LSO barrier enforcement, abort record filtering, control marker accounting, producer reuse consistency, and correctness of claimed visible offsets against actual batch composition.","failureModes":["Mismatched batch count between artifact and claims causes validation rejection","Claimed visible offsets exceed high watermark or violate LSO barrier — returns inconsistency error","Active transaction count conflicts with control records below watermark — flags claim mismatch","Producer ID out of valid range (exceeds 4294967295) causes schema rejection","Batch record count exceeds maximum of 64 per batch — returns validation error","Incomplete prefix flag mismatch (complete_uncompacted_prefix false) may cause indeterminate result","Fetch offset greater than high watermark causes logical consistency failure"],"whenToPreferThis":"Use this endpoint when an AI agent needs to verify the correctness of Kafka read_committed consumer semantics on a captured partition prefix before trusting or adopting a fetch model. It is specifically suited for validating synthetic or replayed Kafka logs that include transactional batches, abort markers, control records, and producer reuse scenarios — situations where manual verification of LSO barriers and abort filtering is error-prone. Prefer this over generic log validators when the scenario involves transactional isolation correctness in Kafka.","instructions":null,"reviewSummary":null,"reviewSummaryHighlights":null,"reviewSummaryConcerns":null,"reviewSummaryGeneratedAt":null,"activationCount":0,"lastUsedAt":null,"lastSuccessfullyRanAt":null,"lastHealthCheckAt":"2026-11-04T06:38:29.173Z","isFirstParty":false,"canonicalSlug":"kafka-committed-prefix-abort-visibility-validator-30349b2d"}