Releases: getsentry/arroyo
Releases · getsentry/arroyo
2.16.2
Various fixes & improvements
- feat: Increase backpressure threshold to 5 seconds (#340) by @lynnagara
2.16.1
Various fixes & improvements
- ref(metrics): Add pause/resume counters [INC-626] (#338) by @untitaker
- perf: inline now calling
coarsetime::Instant
(#336) by @anonrig
2.16.0
Various fixes & improvements
- Add flexible Reduce strategy type (#333) by @cmanallen
- fix(release): Stop releasing to crates.io while it doesn't work (#335) by @untitaker
- feat(logs): Add partition info upon assignment and revocation (#334) by @ayirr7
- ref: Restore owners on rust-arroyo (#330) by @untitaker
- fix: Rename Rust arroyo metric since it has a different unit (#329) by @untitaker
- fix(rust): Add feature to Reduce to flush empty batches (#332) by @untitaker
- ref: Add release workflow for Rust (#327) by @untitaker
- ref(ci): Add Rust CI (#324) by @untitaker
- Revert "ref: Move rust-arroyo from snuba to arroyo" (#325) by @untitaker
- ref: Move rust-arroyo from snuba to arroyo (#323) by @untitaker
- move rust-arroyo to subdirectory (#323) by @untitaker
- fix(multiprocessing): Implement better error messages for block overflow (#322) by @untitaker
- rust: add rust concurrency metric (#5341) by @untitaker
- ref(rust): Don't panic in RunTaskInThreads::poll (#5387) by @untitaker
- deps(rust): Change rdkafka dep to upstream master (#5386) by @untitaker
- ref(metrics): Refactor how global tags work, and introduce min_partition tag (#5346) by @untitaker
- Add Metrics impl based on
merni
(#5351) by @untitaker - fix: Remove any panics in threads (#5353) by @untitaker
- ref(devserver): Use Rust consumers almost everywhere, and fix commitlog implementation (#5311) by @untitaker
- Avoid calling
Topic::new
for every received Message (#5331) by @untitaker - Reuse Tokio Handle in DlqPolicy (#5329) by @untitaker
- ref(rust): Log actual error if strategy panics (#5317) by @untitaker
- fix(rust): add testcase for empty batches (#5299) by @untitaker
- Revert "ref(rust): Do not do extra work when merging if not needed (#5294)" (#323) by @untitaker
Plus 146 more
2.15.4
Various fixes & improvements
- ref: Add release workflow for Rust (#327) by @untitaker
- ref(ci): Add Rust CI (#324) by @untitaker
- Revert "ref: Move rust-arroyo from snuba to arroyo" (#325) by @untitaker
- ref: Move rust-arroyo from snuba to arroyo (#323) by @untitaker
- move rust-arroyo to subdirectory (#323) by @untitaker
- fix(multiprocessing): Implement better error messages for block overflow (#322) by @untitaker
- rust: add rust concurrency metric (#5341) by @untitaker
- ref(rust): Don't panic in RunTaskInThreads::poll (#5387) by @untitaker
- deps(rust): Change rdkafka dep to upstream master (#5386) by @untitaker
- ref(metrics): Refactor how global tags work, and introduce min_partition tag (#5346) by @untitaker
- Add Metrics impl based on
merni
(#5351) by @untitaker - fix: Remove any panics in threads (#5353) by @untitaker
- ref(devserver): Use Rust consumers almost everywhere, and fix commitlog implementation (#5311) by @untitaker
- Avoid calling
Topic::new
for every received Message (#5331) by @untitaker - Reuse Tokio Handle in DlqPolicy (#5329) by @untitaker
- ref(rust): Log actual error if strategy panics (#5317) by @untitaker
- fix(rust): add testcase for empty batches (#5299) by @untitaker
- Revert "ref(rust): Do not do extra work when merging if not needed (#5294)" (#323) by @untitaker
- ref(rust): Remove explicit buffering of gauges (#5293) by @untitaker
- doc: Add some notes to the fine-tuning section of RunTaskWithMultiprocessing, based on work in SBC (#321) by @untitaker
- ref(rust): Do not do extra work when merging if not needed (#5294) by @untitaker
- feat(rust): Add number of rows processed to the batch size instead of 1 (#5284) by @untitaker
- ref: Run CI on python 3.12 (#320) by @lynnagara
- fix(rust): Remove print stmt (#5269) by @untitaker
Plus 140 more
2.15.3
Various fixes & improvements
- fix: Make
arroyo.consumer.latency
a timing metric (#316) by @lynnagara
2.15.2
Various fixes & improvements
- fix(dlq): Ensure consumer crashes if DLQ limit is reached (#314) by @lynnagara
- fix(multiprocessing): Reset pool if tasks are not completed (#315) by @lynnagara
2.15.1
Various fixes & improvements
- fix(filter): Handle MessageRejected correctly (INC-584) (#313) by @untitaker
2.15.0
Various fixes & improvements
- feat: Reusable multiprocessing pool (#311) by @lynnagara
- ref: Combine DlqLimitState methods (#312) by @loewenheim
2.14.25
Various fixes & improvements
- ref: Add more metrics for slow rebalancing (#310) by @untitaker
2.14.24
Various fixes & improvements
- fix(dlq): Actually respect the DLQ limits (#309) by @lynnagara