confluentinc/parallel-consumer

View on GitHub

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Stars: 299
Forks: 172
Open beginner issues: 0
Indexed issues: 77

Dominant language: Java
License: Apache-2.0
Last GitHub push: May 28, 2026
Latest indexed: Sep 15, 2026
Contributing guide: No contributing guide
Code of conduct: No code of conduct
Beginner labels: good first issue help wanted
PR merge metrics: No merged PRs in 30d

Open All

77 open issues indexed

Micrometer metrics Open

enhancement medium

confluentinc/parallel-consumer#27 · 3 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Health-checks Open

medium

confluentinc/parallel-consumer#71 · 4 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Allow customization of the ThreadPoolExecutor Open

confluentinc/parallel-consumer#78 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Matrix test against multiple AK and JDK versions in GH Open

confluentinc/parallel-consumer#103 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Review serialisation versioning strategy with ks and core team Open

confluentinc/parallel-consumer#109 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
javadoc: Clarify how to return tombstone messages from the consume / produce loops Open

confluentinc/parallel-consumer#115 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Remove static state manipulation in tests Open

confluentinc/parallel-consumer#130 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
mvn compile fails if test-jar of parallel-consumer-core was not previously installed / deployed. Open

confluentinc/parallel-consumer#162 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add support for JDK's CompletableFuture into the API as part of the Reactor.io API, add docs Open

confluentinc/parallel-consumer#170 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Spring boot example Open

confluentinc/parallel-consumer#171 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Release train for 1.0 Open

high

confluentinc/parallel-consumer#172 · 10 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Investigate using Release Drafter Open

confluentinc/parallel-consumer#177 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
How to take a single message, and distribute it to several http end points in parallel, with DLQ for failure Open

confluentinc/parallel-consumer#178 · 2 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
vertxHttpReqInfo only supports GET (Unable to call HTTP POST or PUT etc) Open

enhancement help wanted low

confluentinc/parallel-consumer#180 · 20 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Ensure all PC API's are thread safe Open

blocker ver:1.0

confluentinc/parallel-consumer#186 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Feature Request: Unique thread names for PC instances for logging Open

confluentinc/parallel-consumer#192 · 6 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Provide option for max retires, and a call back when reached (potential DLQ) Open

confluentinc/parallel-consumer#196 · 5 comments · 4 reactions · 0 assignees · Indexed Sep 15, 2026
Refactor: Consider a shared nothing architecture, to reduce thread complexity Open

confluentinc/parallel-consumer#200 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Refactor OffsetMapCodecManager.java Open

confluentinc/parallel-consumer#233 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Try refactoring WC type from String to Enum Open

confluentinc/parallel-consumer#241 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Consider adopting error prone and checker Open

confluentinc/parallel-consumer#259 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
feature: Option for batch to only contain messages of the same key Open

good first issue

confluentinc/parallel-consumer#266 · 10 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Refactor test base Open

confluentinc/parallel-consumer#290 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
POC for project Loom integration for light weight threads (higher concurrency without Vert.x or Reactor) Open

confluentinc/parallel-consumer#299 · 3 comments · 5 reactions · 0 assignees · Indexed Sep 15, 2026
Handle deserialization exceptions thrown from the deserialiser Open

confluentinc/parallel-consumer#304 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add a dead letter queue (DQL) implementation Open

confluentinc/parallel-consumer#310 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
With KEY ordering, option to combine queues from different partitions or topics Open

confluentinc/parallel-consumer#314 · 4 comments · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Transparent large message chunking and reconstruction Open

confluentinc/parallel-consumer#321 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Disk backed Produce queue Open

confluentinc/parallel-consumer#322 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Error in onPartitionsAssigned in parallel consumer Open

not-a-bug

confluentinc/parallel-consumer#326 · 15 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Serialization error handling / flexibility Open

enhancement

confluentinc/parallel-consumer#391 · 1 comment · 1 reaction · 0 assignees · Indexed Sep 15, 2026
feature: Option to have Producer send records to least loaded broker Open

confluentinc/parallel-consumer#394 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Max loading factor steps reached: 100/100 Open

confluentinc/parallel-consumer#402 · 20 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Question: Is it possible to produce events using reactor? Open

enhancement not-a-bug question

confluentinc/parallel-consumer#480 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Question: Does Parallel-consumer have state that we can read from? Open

question

confluentinc/parallel-consumer#484 · 11 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
major: Safe User API exposure of ALL Consumer APIs (seek, end offsets etc) Open

confluentinc/parallel-consumer#520 · 1 comment · 0 reactions · 1 assignee · Indexed Sep 15, 2026
Move LongPollingMockConsumer to main artefact Open

confluentinc/parallel-consumer#526 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Apply backpressure per partition instead of the entire assignment Open

enhancement

confluentinc/parallel-consumer#540 · 7 comments · 2 reactions · 0 assignees · Indexed Sep 15, 2026
Why use of Scheduler if the processing has been proven NON blocking please? Open

confluentinc/parallel-consumer#543 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Truncating state Open

confluentinc/parallel-consumer#546 · 23 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Is There Any Exception Handler? Open

confluentinc/parallel-consumer#550 · 5 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Batching not working as expected Open

confluentinc/parallel-consumer#551 · 5 comments · 1 reaction · 0 assignees · Indexed Sep 15, 2026
Feature suggestion: Minimum batch size + batch max wait time Open

confluentinc/parallel-consumer#560 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
When parallel consumer does not close kafka consumer if commmit fails during close Open

confluentinc/parallel-consumer#597 · 8 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Wrong multiplier value in retry delay function example Open

good first issue

confluentinc/parallel-consumer#622 · 4 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Missing topic and offset infos when login error in ConsumerOffsetCommitter Open

good first issue

confluentinc/parallel-consumer#629 · 3 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Warning log to verbose in RemovedPartitionState Open

good first issue

confluentinc/parallel-consumer#631 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Error log to verbose in AbstractParallelEoSStreamProcessor Open

enhancement good first issue

confluentinc/parallel-consumer#640 · 2 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Add explanation of close modes to documentation Open

documentation

confluentinc/parallel-consumer#642 · 1 comment · 0 reactions · 0 assignees · Indexed Sep 15, 2026
Missing feature to terminate processing Open

enhancement

confluentinc/parallel-consumer#718 · 7 comments · 0 reactions · 0 assignees · Indexed Sep 15, 2026

confluentinc/parallel-consumer

Get new issues in your inbox