0.6.0.0

List view

Release 0.6.0.0 - the fork's first release

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

area/release-healthArea: release-healthArea: release-health

choreMaintenance work, no user-visible behaviour changeMaintenance work, no user-visible behaviour change

Status: Open.

#197 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

feat(api) #126: health-check surface on the ParallelConsumer interface

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 226

#226 In astubbs/parallel-consumer;

· astubbs opened on Aug 7, 2026

ci(release) astubbs#197: publish the curated changelog section as the GitHub Release body

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 199

#199 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

feat(connect-spike) astubbs#240: Connect sinks on PC - direction, offset analysis, and the shadowing proof (confluentinc#119)

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 269

#269 In astubbs/parallel-consumer;

· astubbs opened on Aug 10, 2026

build(streams) astubbs#255: patch Kafka Streams at build time, with Kafka's own suite as the oracle

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 379

#379 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 388

#388 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 389

#389 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 391

#391 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 394

#394 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 395

#395 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 396

#396 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

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.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 398

#398 In astubbs/parallel-consumer;

· astubbs opened on Aug 31, 2026

confluentinc#857: Paused consumption across multiple consumers

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

area/reliabilityCorrectness under rebalance, commit and shutdownCorrectness under rebalance, commit and shutdown

bugSomething isn't workingSomething isn't working

partially-fixed-in/0.5.3.3Partly addressed in 0.5.3.3Partly addressed in 0.5.3.3

pr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstream

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#119 In astubbs/parallel-consumer;

· astubbs opened on Aug 4, 2026

confluentinc#809: Sporadic timeouts from ConsumerOffsetCommitter.CommitRequest

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

area/reliabilityCorrectness under rebalance, commit and shutdownCorrectness under rebalance, commit and shutdown

bugSomething isn't workingSomething isn't working

partially-fixed-in/0.5.3.1Partly addressed in 0.5.3.1Partly addressed in 0.5.3.1

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#175 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

confluentinc#259: Consider adopting error prone and checker

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

area/build-testArea: build-testArea: build-test

choreMaintenance work, no user-visible behaviour changeMaintenance work, no user-visible behaviour change

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#144 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

confluentinc#896: Add support for virtual threads

area/compatArea: compatArea: compat

featureNew capability or improvement to an existing oneNew capability or improvement to an existing one

next-breaking-releaseTargeted at the next breaking release (API or architecture change)Targeted at the next breaking release (API or architecture change)

pr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstream

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#190 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

feat(core) astubbs#190: run the user function on virtual threads

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 360

#360 In astubbs/parallel-consumer;

· astubbs opened on Aug 25, 2026

confluentinc#310: Add a dead letter queue (DQL) implementation

area/error-handlingArea: error-handlingArea: error-handling

featureNew capability or improvement to an existing oneNew capability or improvement to an existing one

next-feature-releaseTargeted at the next feature release (additive, non-breaking)Targeted at the next feature release (additive, non-breaking)

pr-availableAn implementation exists in a PR - open here, or orphaned upstreamAn implementation exists in a PR - open here, or orphaned upstream

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#149 In astubbs/parallel-consumer;

· astubbs opened on Aug 5, 2026

docs #149: DLQ brainstorm - prior art, requirements, discussion

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 313

#313 In astubbs/parallel-consumer;

· astubbs opened on Aug 18, 2026

START: DLQ draft

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Draft (not ready).

astubbs/parallel-consumernumber 8

#8 In astubbs/parallel-consumer;

· astubbs opened on May 20, 2022

feat(core): a commit-failure seam, so the application decides instead of PC always terminating

featureNew capability or improvement to an existing oneNew capability or improvement to an existing one

Status: Open.

#317 In astubbs/parallel-consumer;

· astubbs opened on Aug 19, 2026

feat(core) astubbs#317: a commit-failure seam - the application decides instead of PC always terminating

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

featureNew capability or improvement to an existing oneNew capability or improvement to an existing one

Status: Draft (not ready).

astubbs/parallel-consumernumber 352

#352 In astubbs/parallel-consumer;

· astubbs opened on Aug 25, 2026

build(deps): bump junit.version from 5.10.2 to 6.1.2

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

dependenciesPull requests that update a dependency filePull requests that update a dependency file

javaPull requests that update java codePull requests that update java code

Status: Draft (not ready).

astubbs/parallel-consumernumber 38

#38 In astubbs/parallel-consumer;

· dependabot opened on Apr 15, 2026

confluentinc#803: Transactional Producer instance gets timeout getting commit lock while second instance starts

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

area/reliabilityCorrectness under rebalance, commit and shutdownCorrectness under rebalance, commit and shutdown

bugSomething isn't workingSomething isn't working

upstream-mirrorMirrored from the upstream confluentinc trackerMirrored from the upstream confluentinc tracker

Status: Open.

#44 In astubbs/parallel-consumer;

· astubbs opened on Apr 18, 2026

When will the first stable fork release be published to Maven Central?

0.6.0.0Targeted at the 0.6.0.0 releaseTargeted at the 0.6.0.0 release

Status: Open.

#52 In astubbs/parallel-consumer;

· renatojava opened on Jul 18, 2026