astubbs / parallel-consumer Public

forked from confluentinc/parallel-consumer

Notifications You must be signed in to change notification settings
Fork 8
Star 27

Code
Issues 98
Pull requests 70
Actions
Projects
Security and quality
Insights

Additional navigation options

Code
Issues
Pull requests
Actions
Projects
Security and quality
Insights

Pull requests: astubbs/parallel-consumer

Labels 50 Milestones 1

New pull request New

70 Open 245 Closed

Author

Filter by author

Uh oh!

There was an error while loading. Please reload this page.

Label

Filter by label

Uh oh!

There was an error while loading. Please reload this page.

Use alt + click/return to exclude labels

or ⇧ + click/return for logical OR

Projects

Filter by project

Uh oh!

There was an error while loading. Please reload this page.

Milestones

Filter by milestone

Uh oh!

There was an error while loading. Please reload this page.

Reviews

Filter by reviews

No reviews Review required Approved review Changes requested

Assignee

Filter by who’s assigned

Assigned to nobody

Uh oh!

There was an error while loading. Please reload this page.

Sort

Sort by

Newest Oldest Most commented Least commented Recently updated Least recently updated Best match

Most reactions

Pull requests list

ci(integration): split the gate into one named heavy set and a catch-all

#442 opened Sep 4, 2026 by astubbs Owner

Loading…

6 tasks done

fix(test): the random chaos monkey can never pick its last victim

#441 opened Sep 3, 2026 by astubbs Owner

Loading…

1 of 6 tasks

ci(build): check in the Maven wrapper jar so a lane cannot die before Maven starts

#440 opened Sep 3, 2026 by astubbs Owner

Loading…

6 tasks done

perf(ci): stop building javadoc and sources jars in the integration lane, and close forkCount as a lever

#439 opened Sep 3, 2026 by astubbs Owner

Loading…

6 tasks done

feat(inflight): rank the open backlog across every ref, and diff it against the standing ranking

#438 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

fix(core): close the retry-queue orphan window by confirming shard residency after the add

#437 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

test(core): the revoke-path commit omits offsets for records it already produced

#436 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

test(chaos) astubbs#119: classify the instance-stall line, and correct two claims wider than the code

#435 opened Sep 3, 2026 by astubbs Owner

Loading…

6 tasks done

fix(core): abort a transaction poisoned by a terminal send failure

#434 opened Sep 3, 2026 by astubbs Owner • Draft

5 of 6 tasks

refactor(core): run the infer-annotation experiments - two confinement declarations, and a measurement of the rest

#433 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

fix(core): the rebalance callbacks decline the retry queue's write lock instead of waiting for it

#431 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

fix(logging) astubbs#168: bound the commit-error line, keep every offset

#428 opened Sep 3, 2026 by astubbs Owner • Draft

6 tasks done

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

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

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

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

test(streams) astubbs#255: the evidence suite - a seam-on divergence lane, the broker-backed laws, and a benchmark with a noise floor 0.6.0.0

Targeted at the 0.6.0.0 release

#398 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(streams) astubbs#255: advance stream time on the PC path, and decide what to do about punctuation 0.6.0.0

Targeted at the 0.6.0.0 release

#396 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(streams) astubbs#255: deliver worker failures and buffer pressure into Kafka Streams' own control paths 0.6.0.0

Targeted at the 0.6.0.0 release

#395 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(streams) astubbs#255: carry PC task ownership through Streams' task lifecycle and rebalance 0.6.0.0

Targeted at the 0.6.0.0 release

#394 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(core) astubbs#228: hasten navigator micro-MVP - soft shared-resource credits / global rate limiting v1

#392 opened Aug 31, 2026 by astubbs Owner • Draft

3 of 6 tasks

feat(streams-example) astubbs#255: a runnable demo of Kafka Streams on PC, with the controls that keep it honest 0.6.0.0

Targeted at the 0.6.0.0 release

#391 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(clients) astubbs#242: ten foreign dispatch clients, and the runner registry that will drive them

#390 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

feat(streams) astubbs#255: refuse the Kafka Streams surface PC dispatch cannot run safely 0.6.0.0

Targeted at the 0.6.0.0 release

#389 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

feat(streams) astubbs#255: run a Kafka Streams topology on PC per-key concurrency, behind an opt-in switch 0.6.0.0

Targeted at the 0.6.0.0 release

#388 opened Aug 31, 2026 by astubbs Owner • Draft

5 tasks done

0.6.0.0

Previous 1 2 3 Next

Previous Next

ProTip! Type g i on any issue or pull request to go back to the issue listing page.