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.
active 2023-08-15 → 2026-08-11 (UTC)
Activity over time
Daily event counts in the loaded window
Line chart, 1093 days from 2023-08-15 to 2026-08-11. Pushes: 448 total, peak 46 in a day. Pull requests: 335 total, peak 41 in a day. Issues: 104 total, peak 4 in a day. Comments: 660 total, peak 38 in a day. Stars: 332 total, peak 5 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 |
|---|---|---|---|---|
| rkolesnev | 657 | 149 | 131 | 265 |
| dependabot[bot] | 176 | 62 | 86 | 28 |
| ConfluentJenkins | 133 | 118 | 8 | 7 |
| sangreal | 131 | 0 | 18 | 82 |
| cla-assistant[bot] | 79 | 0 | 0 | 79 |
| service-bot-app[bot] | 72 | 60 | 5 | 7 |
| eddyv | 49 | 2 | 2 | 11 |
| johnbyrnejb | 33 | 12 | 11 | 0 |
| renovatebot-confluentinc[bot] | 26 | 12 | 14 | 0 |
| cprovencher | 20 | 2 | 18 | 0 |
| gtassone | 16 | 0 | 1 | 13 |
| ConfluentSemaphore | 15 | 15 | 0 | 0 |
| nscuro | 14 | 0 | 2 | 10 |
| dumontxiong | 13 | 0 | 0 | 7 |
| airlock-confluentinc[bot] | 13 | 13 | 0 | 0 |
| what-the-diff[bot] | 12 | 0 | 0 | 12 |
| mikhelef | 9 | 0 | 1 | 5 |
| antonmos | 9 | 0 | 1 | 8 |
| wushilin | 7 | 0 | 2 | 2 |
| Satrix | 7 | 0 | 0 | 5 |
Recent activity
Latest issues, pull requests and releases
- Issue comment#857astubbs2026-04-09 23:07Paused consumption across multiple consumers
- Issue comment#908Add0z2026-02-15 13:45[Feature] Support Virtual Threads
- Issue comment#913service-bot-app[bot]2026-01-29 05:12chore(deps): update dependency org.assertj:assertj-core to v3.27.7 [security] (master)
- Pull request#913renovatebot-confluentinc[bot]2026-01-29 03:14
- Issue comment#896mageddo2026-01-27 23:01Add support for virtual threads
- Issue comment#266mageddo2026-01-27 22:54feature: Option for batch to only contain messages of the same key
- Issue comment#911service-bot-app[bot]2026-01-26 06:20chore(deps): update dependency ch.qos.logback:logback-core to v1.5.25 [security] (master)
- Pull request#911renovatebot-confluentinc[bot]2026-01-26 03:14
- Issue comment#647zhishengzhang2026-01-16 09:42Offset map data too large warnings
- Issue comment#857amrynsky2026-01-11 07:22Paused consumption across multiple consumers
- Issue#907amrynsky2026-01-10 23:37Is the project still actively maintained?
- Issue comment#902lutzh2026-01-09 14:13Always process the freshest record when ordered by key
- Pull request#905flashmouse2026-01-04 09:59
- Issue#904leonardotorresaltez2025-12-17 22:04support for Kafka 4.0.x
- Issue comment#857sangreal2025-12-09 13:56Paused consumption across multiple consumers
- Issue comment#893sangreal2025-12-03 01:21make committed offset accurate when partition assigned to avoid offset reset
- Pull request#901johnbyrnejb2025-10-28 22:03
- Pull request#900dependabot[bot]2025-10-28 16:05
- Pull request#900dependabot[bot]2025-10-28 16:05
- Pull request#899dependabot[bot]2025-10-28 16:04
- Pull request#899dependabot[bot]2025-10-28 16:04
- Pull request#899dependabot[bot]2025-10-28 16:04
- Pull request#899dependabot[bot]2025-10-28 16:04
- Pull request#898dependabot[bot]2025-10-28 16:04
- Issue comment#892priesus2025-10-28 14:17Keep instantiated OffsetMapCodecManager so that metrics will not be recreated every commit #859
Totals cover only the window loaded into ClickHouse and count events, not GitHub's lifetime totals — 332 stars here means stars gained during the window, not the repo's star count.