astubbs

astubbs/parallel-consumer

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

10 good first / help-wanted issues · Java · last activity Aug 4, 2026

15 stars 5 forks 15 watchers Java Apache License 2.0
View on GitHub
10 Open Issues Need Help Last updated: Aug 4, 2026

Open Issues Need Help

View All on GitHub
confluentinc#71: Health-checks 12 days ago
feature good first issue upstream-mirror area/observability pr-available next-breaking-release
astubbs/parallel-consumer
15

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

Java
confluentinc#640: Error log to verbose in AbstractParallelEoSStreamProcessor 18 days ago
feature good first issue 0.6.0.0 upstream-mirror area/observability
astubbs/parallel-consumer
15

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

Java
confluentinc#629: Missing topic and offset infos when login error in ConsumerOffsetCommitter 18 days ago
feature good first issue 0.6.0.0 upstream-mirror area/observability
astubbs/parallel-consumer
15

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

Java
Publish the docs as a versioned documentation site, not one 1578-line README about 1 month ago
documentation feature help wanted good first issue chore area/docs next-feature-release
astubbs/parallel-consumer
15

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

Java
confluentinc#267: docs: Comparison to Spring Cloud Stream Kafka binder about 1 month ago
documentation help wanted upstream-mirror area/docs upstream-admin-closed
astubbs/parallel-consumer
15

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

Java
confluentinc#191: Need ability to seek to the beginning of a partition about 1 month ago
feature good first issue upstream-mirror area/api pr-available upstream-admin-closed
astubbs/parallel-consumer
15

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

Java
confluentinc#180: vertxHttpReqInfo only supports GET (Unable to call HTTP POST or PUT etc) about 1 month ago
help wanted question upstream-mirror area/modules next-feature-release
astubbs/parallel-consumer
15

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

Java
confluentinc#266: feature: Option for batch to only contain messages of the same key about 1 month ago
feature good first issue upstream-mirror area/batching-ordering next-feature-release
astubbs/parallel-consumer
15

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

Java
confluentinc#631: Warning log to verbose in RemovedPartitionState about 1 month ago
feature good first issue 0.6.0.0 upstream-mirror area/observability
astubbs/parallel-consumer
15

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

Java
upstream #622: Wrong multiplier value in retry delay function example about 1 month ago
bug good first issue 0.6.0.0 upstream-mirror area/docs pr-available
astubbs/parallel-consumer
15

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

Java