Issues

• Memory usage keeps increasing after each processing cycle with Parallel Consumer (v0.6.0.0)

  astubbs/parallel-consumer#527 · Filter by author dario-antonio-lassoni opened on Sep 30, 2026

• UX modernisation: a fluent API beside the classic one, park in place, and a broker-free sandbox

  feature
  astubbs/parallel-consumer#504 · Filter by author astubbs opened on Sep 10, 2026
  

• confluentinc#830: PC loops forever on InvalidPidMappingException instead of replacing the producer

  area/reliabilitybugnext-patch-releaseupstream-mirror
  astubbs/parallel-consumer#411 · Filter by author astubbs opened on Sep 2, 2026
  1

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

  feature
  astubbs/parallel-consumer#317 · Filter by author astubbs opened on Aug 19, 2026 · 0.6.0.0

• Batching requests a full extra in-flight target of work, and batchSize is unvalidated

  area/batching-orderingbugverified bug
  astubbs/parallel-consumer#311 · Filter by author astubbs opened on Aug 18, 2026 · 0.6.0.0
  1

• Upstream closure follow-up: the decisions nobody has made yet

  astubbs/parallel-consumer#300 · Filter by author astubbs opened on Aug 14, 2026

• Kafka Streams: give a Streams topology PC's per-key parallelism

  area/internalsarea/performancefeaturepr-available
  astubbs/parallel-consumer#255 · Filter by author astubbs opened on Aug 7, 2026 · 0.6.0.0
  1

  

• confluentinc#372: Have processing functions attached to topics instead of a global one for all subscribed topics

  area/apifeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#254 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#320: Extend parallel consumer to be able to include multiple consumers/producers of different clusters

  area/modulesfeatureupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#253 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#267: docs: Comparison to Spring Cloud Stream Kafka binder

  area/docsdocumentationhelp wantedupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#251 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#246: Consider turning on code sorting in the formatter

  area/build-testchorenot-a-bugupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#250 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#205: vert.x: Run user funtions in a Vertical instead of Java thread pool

  area/modulesfeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#249 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#199: Dynamic reason support for failfast in awaitility

  area/build-testchoreupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#247 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#191: Need ability to seek to the beginning of a partition

  area/apifeaturegood first issuepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#246 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#187: Enable changing of topic subscription before or after PC has started

  area/apifeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#245 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#183: Feature: Allow unordered processing of messages without a key in 'KEY' ordering mode

  area/batching-orderingfeatureupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#244 · Filter by author astubbs opened on Aug 7, 2026
  2

• confluentinc#175: Ability use different consume and produce types for the key and value

  area/apifeaturenext-breaking-releaseupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#243 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#154: Integrate into a Proxy so can support any language and a server side queue implementation

  area/modulesfeatureupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#242 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#144: ProducerManager should handle different types of transaction failures appropriately

  area/reliabilityfeatureupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#241 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#119: Integration with Kafka Connect

  area/modulesfeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#240 · Filter by author astubbs opened on Aug 7, 2026 · 0.6.0.0
  1

• confluentinc#65: Enhanced retry epic

  area/error-handlingfeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#239 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#57: Reduce debug log output

  area/observabilitychoreupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#238 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#53: Exact continuous offset encoding for precise offset payload size back pressure

  area/internalsfeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#237 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#50: Feature: When subscribing to multiple topics, have the ability to priorities topics over others

  area/batching-orderingfeaturepr-availableupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#236 · Filter by author astubbs opened on Aug 7, 2026

• confluentinc#49: Feature: Run mode where transition to plain offset committing (no encoded offsets needed)

  area/internalsfeatureupstream-admin-closedupstream-mirror
  astubbs/parallel-consumer#235 · Filter by author astubbs opened on Aug 7, 2026