Parallel Apache Kafka client wrapper with client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
active 2026-04-09 → 2026-08-10 (UTC)
Activity over time
Daily event counts in the loaded window
Line chart, 124 days from 2026-04-09 to 2026-08-10. Pushes: 172 total, peak 16 in a day. Pull requests: 12 total, peak 3 in a day. Issues: 4 total, peak 2 in a day. Comments: 34 total, peak 7 in a day. Stars: 1 total, peak 1 in a day.
- Pushes
- Pull requests
- Issues
- Comments
- Stars
Stars, PRs, issues and forks are under-captured in the later part of this window. GH Archive progressively stopped capturing non-push events during 2026 — −95% or worse by the end of the window. Every series here except Pushes fades for that reason, so a decline above reflects the archive, not this repository. Pushes stay reliable throughout, so read them, and the contributor counts derived from them, as the real signal. Data health has the measurements.
Top contributors
Pushes, PRs, issues, reviews and comments — stars and forks excluded, so this is contribution rather than popularity
| Contributor | Contributions | Pushes | PRs | Comments |
|---|---|---|---|---|
| astubbs | 185 | 166 | 9 | 3 |
| github-actions[bot] | 34 | 0 | 0 | 23 |
| dependabot[bot] | 8 | 5 | 3 | 0 |
| claude[bot] | 5 | 1 | 0 | 3 |
| codecov-commenter | 2 | 0 | 0 | 2 |
| netroute-js | 1 | 0 | 0 | 1 |
| youribonnaffe | 1 | 0 | 0 | 1 |
| github-advanced-security[bot] | 1 | 0 | 0 | 1 |
Recent activity
Latest issues, pull requests and releases
- Issue#167astubbs2026-08-05 00:28upstream #622: Wrong multiplier value in retry delay function example
- Issue#149astubbs2026-08-05 00:27upstream #310: Add a dead letter queue (DQL) implementation
- Pull request#99dependabot[bot]2026-07-31 18:53
- Issue comment#25youribonnaffe2026-06-07 20:55Rebrand fork + CI overhaul: io.github.astubbs.parallelconsumer 0.6.0.0-SNAPSHOT
- Issue comment#29netroute-js2026-04-24 07:23Fix #857: Paused consumption after rebalance with multiple consumers
- Issue comment#50codecov-commenter2026-04-22 00:45fix(publish): skip deploying example modules and empty test-jars
- Issue comment#50github-actions[bot]2026-04-22 00:42fix(publish): skip deploying example modules and empty test-jars
- Pull request#49astubbs2026-04-21 23:41
- Issue comment#49github-actions[bot]2026-04-21 05:24ci: drop Kafka 3.1.0 from version matrix, extend build timeout
- Pull request#48astubbs2026-04-21 04:15
- Issue comment#48github-actions[bot]2026-04-21 03:56ci: extend prepare-deps cache warming to push builds
- Issue comment#48github-actions[bot]2026-04-21 03:56ci: extend prepare-deps cache warming to push builds
- Issue comment#48github-actions[bot]2026-04-21 03:51ci: extend prepare-deps cache warming to push builds
- Issue comment#47github-actions[bot]2026-04-21 02:02build(deps-dev): bump the maven group across 1 directory with 2 updates
- Pull request#45astubbs2026-04-21 00:27
- Issue comment#31github-actions[bot]2026-04-20 23:01fix: replace stale container at same offset after rebalance (#909)
- Issue comment#31github-actions[bot]2026-04-20 22:48fix: replace stale container at same offset after rebalance (#909)
- Pull request#30astubbs2026-04-20 22:46
- Issue comment#29astubbs2026-04-20 07:26Fix #857: Paused consumption after rebalance with multiple consumers
- Pull request#45astubbs2026-04-18 04:17
- Issue comment#43github-actions[bot]2026-04-18 03:29feat: add max-queued-records-per-shard metric (cherry-pick Confluent #905)
- Issue comment#43github-actions[bot]2026-04-18 03:29feat: add max-queued-records-per-shard metric (cherry-pick Confluent #905)
- Issue comment#42codecov-commenter2026-04-18 03:23fix: make committed offset accurate on partition assignment (cherry-pick Confluent #893)
- Issue comment#42github-actions[bot]2026-04-18 03:13fix: make committed offset accurate on partition assignment (cherry-pick Confluent #893)
- Pull request#43astubbs2026-04-18 00:20
Totals cover only the window loaded into ClickHouse and count events, not GitHub's lifetime totals — 1 stars here means stars gained during the window, not the repo's star count.