Skip to content

Pull requests: astubbs/parallel-consumer

New pull request New
74 Open 319 Closed
74 Open 319 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

test(core) confluentinc#682: the PARTITION-order starvation the README describes is asserted at the gate, not raced at a broker
#521 opened Sep 18, 2026 by astubbs Owner Loading…
6 tasks done
9
fix(core) astubbs#178: a re-delivered key waits for the flight a revoke swept out of its shard
#517 opened Sep 18, 2026 by astubbs Owner Loading…
6 tasks done
1
31
docs(release) astubbs#197: the post-tag sweep - the drafts are posted, the burn-down is retired, and what the release still owes is one note
#516 opened Sep 17, 2026 by astubbs Owner Loading…
6 tasks done
25
feat(observability) astubbs#215: extract the state-reading substrate the dashboard and MCP both project
#514 opened Sep 12, 2026 by astubbs Owner Loading…
6 tasks done
17
docs(release): open the 6.1 scope note - performance and UX, and seven targets
#513 opened Sep 12, 2026 by astubbs Owner Loading…
6 tasks done
16
feat(sandbox) astubbs#504: realistic record values - fake orders, parcels and Avro payloads
#512 opened Sep 12, 2026 by astubbs Owner • Draft
6 tasks done
5
feat(fluent) astubbs#504: the dead-letter surface, with the reaction verb it was missing
#511 opened Sep 12, 2026 by astubbs Owner • Draft
6 tasks done
5
feat(inflight): the docs corpus covers feature records, on every ref
#510 opened Sep 12, 2026 by astubbs Owner • Draft
3 of 6 tasks
5
docs(plans): the Hasten MCP interface - an implementation-ready plan for a read-only hello world
#508 opened Sep 11, 2026 by astubbs Owner Loading…
6 tasks done
53
feat(sandbox) astubbs#504: a broker-free sandbox module - pipe records into either API, read what came out
#507 opened Sep 11, 2026 by astubbs Owner • Draft
5 of 6 tasks
7
feat(core) astubbs#504: a retriable throw carries its delay or parks in place, and pause takes queued work back
#506 opened Sep 11, 2026 by astubbs Owner • Draft
6 tasks done
5
feat(core) astubbs#504: the fluent API and park in place (UX modernisation, Milestone A)
#502 opened Sep 9, 2026 by astubbs Owner • Draft
6 tasks done
1
22
docs(inflight): two notes for refactoring the God class and the five classes below it
#479 opened Sep 8, 2026 by astubbs Owner • Draft
2 of 6 tasks
8
feat(core) astubbs#225: keep every completed record until the commit that carries it succeeds, and be able to put an aborted transaction's work back
#474 opened Sep 7, 2026 by astubbs Owner • Draft
6 tasks done
10
feat(core) astubbs#225: the vocabulary and plumbing producer recovery is built on - what the broker reports, and how PC builds another producer
#472 opened Sep 7, 2026 by astubbs Owner • Draft
6 tasks done
11
test(streams-conformance) astubbs#242: the Streams conformance net, oracle rung
#461 opened Sep 7, 2026 by astubbs Owner • Draft
6 tasks done
Foreign language wrap for Streams
8
feat(offsets) astubbs#255: an opaque rider in the commit-metadata payload, under one envelope magic byte
#460 opened Sep 7, 2026 by astubbs Owner • Draft
6 tasks done
Streams on PC
27
feat(core) astubbs#228: global rate limiting for one application - the partition-share allocator, its proof across JVMs, and the churn ladder WIP
#456 opened Sep 6, 2026 by astubbs Owner • Draft
4 tasks done
@astubbs
10
perf(streams) astubbs#242: the FFI fast-path spike - sub-microsecond crossings, and a mis-specified floor
#455 opened Sep 5, 2026 by astubbs Owner • Draft
5 tasks done
Foreign language wrap for Streams
5
feat(streams) astubbs#255: reconcile the sibling rungs, and decide the dispatch default against the merged whole WIP
#454 opened Sep 5, 2026 by astubbs Owner • Draft
6 tasks done
Streams on PC
@astubbs
5
fix(core): abort a transaction poisoned by a terminal send failure
#434 opened Sep 3, 2026 by astubbs Owner • Draft
6 tasks done
15
feat(core) astubbs#225: derive the transactional.id, build the producer through a factory PC enforces, and redact its configuration
#420 opened Sep 2, 2026 by astubbs Owner • Draft
6 tasks done
25
feat(core) astubbs#225: recover the producer when the broker invalidates it, rather than dying
#410 opened Sep 2, 2026 by astubbs Owner • Draft
6 tasks done
1
53
fix(core) confluentinc#803: a revocation declines the transaction lock instead of waiting on it
#408 opened Sep 1, 2026 by astubbs Owner • Draft
5 of 6 tasks
1
15
test(chaos) confluentinc#857: the overnight torture harness, extracted from the 857 PR
#405 opened Sep 1, 2026 by astubbs Owner • Draft
4 of 6 tasks
6
ProTip! Follow long discussions with comments:>50.