Just finished up a hack week at work and finally got to open source our kafka framework that we use for high throughput consumers (thousands of rps) internally. It’s quite stable, we’ve been using it for years. We wanted more opportunities to build off of it so we bumped the core libraries and have been focused on writing tests and docs. I’ve left it at 0.9-SNAPSHOT until we’re happy with those changes.
It’s “opinionated” so it’s not going to solve all use-cases but we really like it for building individual “cogs” in larger pipelines because it’s simple and surprisingly flexible.