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.

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
Error log to verbose in AbstractParallelEoSStreamProcessor about 9 hours 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 about 9 hours 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 9 hours 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
Wrong multiplier value in retry delay function example about 9 hours 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 about 9 hours 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) about 9 hours 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