ngmi / getsentry / arroyo

getsentry/arroyo

Python 56 stars

A library to build streaming applications that consume from and produce to Kafka.

✓ Synced 1h ago Share on X →
README badge: [![ngmi](https://ngmi.review/badge/getsentry/arroyo.svg)](https://ngmi.review/repo/getsentry/arroyo)
411 Merged PRs
5 days Avg Merge Time
0m Fastest PR
1 year Slowest PR
#1393 Global Speed Rank
Trim top 0% outliers

Trends Over Time

Monthly aggregates for this repo. The gap between avg and median reveals outlier skew.

PR size over time (lines changed)
Review time over time (hrs)
Changes requested rate over time (%)
Merged PRs per month
Time to first review (hrs)
Unreviewed merge rate (%)

PR Size Analysis

Lines changed (additions + deletions) vs review outcomes.

PRs by size
Avg review time (hrs)
Clean approval rate (%)

Top Reviewers

#1 @lynnagara
@lynnagara
283 reviews ✓ 86 approved ↺ 2 blocked
#2
@untitaker
223 reviews ✓ 124 approved ↺ 5 blocked
#3 @fpacifici
@fpacifici
179 reviews ✓ 71 approved ↺ 7 blocked
#4 @evanh
@evanh
107 reviews ✓ 89 approved
#5
@rahul-kumar-saini
63 reviews ✓ 6 approved
#6 @nikhars
@nikhars
28 reviews ✓ 15 approved
#7 @volokluev
@volokluev
22 reviews ✓ 17 approved
#8 @ayirr7
@ayirr7
18 reviews ✓ 9 approved
#9 @onewland
@onewland
14 reviews ✓ 7 approved
#10 @mitsuhiko
@mitsuhiko
12 reviews ✓ 1 approved ↺ 1 blocked

Recent Merged PRs

# Title Author Time Reviews Blocks
#520 Customize SharedMemoryManager subprocess start mode @fpacifici 17.4h 2 ✓
#519 feat(stuck-detector): Add context manager for stuck detector @lvthanh03 4 days 2 ✓
#518 Fix CI @untitaker 21.2h 1 ✓
#517 fix(stuck-detector): Use metrics directly @untitaker 12 days 3 ✓
#516 build(dep): Upgrade to rdkafka 0.38 @Dav1dde 1.3h 2 ✓
#515 Log progress on multiprocess worker @fpacifici 14m 1 ✓
#514 ref(rust): Simplify metrics interface (breaking change) @untitaker 1.6h 2 ✓
#512 ref: Stuck detector @untitaker 2.3h 5 ✓
#513 chore: Fix doc CI @untitaker 2.2h 1 ✓
#510 ref(processor): Do not hard-crash if DLQ buffer is missing a message @untitaker 7m 1 ✓
#509 ref(processor): Turn on handle_poll_while_paused unconditionally @untitaker 20m 1 ✓
#508 ref(consumer): Make autocommit the default @untitaker 26m 1 ✓
#507 ref(consumer): Remove retry-handle-destroyed featureflag @untitaker 26m 1 ✓
#503 ref(processor): Remove shutdown_strategy_before_consumer (breaking) @untitaker 5 days 1 ✓
#504 fix(processor): address new partition after poll @victoria-yining-huang 3 days 11 ✓
#502 add retry_handle_destroyed to configuration.py @bmckerry 4m 2 ✓
#501 feat(consumer): add flag to retry on handle detroyed @bmckerry 1 day 2 ✓
#499 feat(consumer): Add commit status metrics @lvthanh03 20.1h 2 1×
#500 fix(debug): only call poll once when consumer paused @victoria-yining-huang 4m 1 ✓
#491 feat(metrics): Add a metric for total number of available processes @lvthanh03 7 days 4 ✓