Skip to content

0.8.0
Compare
Choose a tag to compare
@iravid iravid released this 15 Apr 21:03
· 811 commits to master since this release
v0.8.0
35cf4f9
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

Notable changes:

  • Eager polling: the consumer will now immediately poll whenever there's demand from the stream. This improves performance considerably (by up to 15x in some benchmarks).
  • Simplified interface for the consumer: the type parameters have been removed from the consumer. This improves the ergonomics of working with the module accessors (Consumer.subscribeAnd, etc.). The tradeoff is that the Serde instances are now specified on Consumer.partitionedStream/plainStream.

Thank you @svroonland for contributing a refactor to the internal consumer runloop!

Assets 2
Loading