confluentinc

confluentinc/parallel-consumer

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.

6 good first / help-wanted issues · Java · last activity Jul 30, 2026

297 stars 169 forks 297 watchers Java Apache License 2.0
kafka kafka-consumer messaging performance queueing
View on GitHub Website
6 Open Issues Need Help Last updated: Jul 30, 2026

Open Issues Need Help

View All on GitHub
Wrong multiplier value in retry delay function example about 2 months ago
good first issue
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing
Missing topic and offset infos when login error in ConsumerOffsetCommitter about 2 months ago
good first issue
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing
Error log to verbose in AbstractParallelEoSStreamProcessor 3 months ago
enhancement good first issue
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing
Warning log to verbose in RemovedPartitionState 3 months ago
good first issue
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing
feature: Option for batch to only contain messages of the same key 3 months ago
good first issue
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing
vertxHttpReqInfo only supports GET (Unable to call HTTP POST or PUT etc) 3 months ago
enhancement help wanted low
confluentinc/parallel-consumer
297

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.

Java
#kafka#kafka-consumer#messaging#performance#queueing