issues
search
getsentry
/
arroyo
A library to build streaming applications that consume from and produce to Kafka.
https://getsentry.github.io/arroyo/
Apache License 2.0
39
stars
6
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
ref: Move rust-arroyo from snuba to arroyo
#323
untitaker
closed
5 months ago
1
fix(multiprocessing): Implement better error messages for block overflow
#322
untitaker
closed
5 months ago
0
doc: Add some notes to the fine-tuning section of RunTaskWithMultiprocessing, based on work in SBC
#321
untitaker
closed
5 months ago
0
ref: Run CI on python 3.12
#320
lynnagara
closed
6 months ago
0
fix(multiprocessing): Increase default block sizes
#319
nikhars
opened
6 months ago
2
docs: patch getting-started example
#318
mj0nez
closed
6 months ago
1
fix(processor): Create strategy lazily on first message
#317
untitaker
opened
6 months ago
0
fix: Make `arroyo.consumer.latency` a timing metric
#316
lynnagara
closed
6 months ago
0
fix(multiprocessing): Reset pool if tasks are not completed
#315
lynnagara
closed
6 months ago
1
fix(dlq): Ensure consumer crashes if DLQ limit is reached
#314
lynnagara
closed
6 months ago
0
fix(filter): Handle MessageRejected correctly (INC-584)
#313
untitaker
closed
6 months ago
0
ref: Combine DlqLimitState methods
#312
loewenheim
closed
6 months ago
0
feat: Reusable multiprocessing pool
#311
lynnagara
closed
6 months ago
1
ref: Add more metrics for slow rebalancing
#310
untitaker
closed
7 months ago
0
fix(dlq): Actually respect the DLQ limits
#309
lynnagara
closed
7 months ago
0
feat: Enable automatic latency recording for consumers
#308
lynnagara
closed
7 months ago
0
Automatically record consumer latency in Arroyo
#307
lynnagara
closed
7 months ago
0
fix: Default input block size should be larger
#306
untitaker
closed
7 months ago
0
fix: Attempt to fix InvalidStateError
#305
lynnagara
closed
7 months ago
0
fix: Try fixing InvalidStateError
#304
lynnagara
closed
7 months ago
3
ref: Rename backpressure metric
#303
lynnagara
closed
7 months ago
1
ref: Add extra logging for debugging commits
#302
lynnagara
closed
7 months ago
0
fix(dlq): RunTaskWithMultiprocessing supports forwarding downstream invalid message
#301
lynnagara
closed
7 months ago
0
fix(run_task_threads): Add metric to capture backpressure
#300
nikhars
closed
7 months ago
2
fix: Cleanup backpressure state between assignments
#299
lynnagara
closed
7 months ago
0
fix: Temporarily bring back support for legacy commit log format
#298
lynnagara
closed
8 months ago
0
fix: Revert change when consumer is paused
#297
lynnagara
closed
8 months ago
0
perf: Avoid unnecessarily clearing the rdkafka buffer on backpressure
#296
lynnagara
closed
8 months ago
0
feat: Add optional received_p99 timestamp to commit log
#295
lynnagara
closed
8 months ago
0
doc: Describe max_batch_size/max_batch_time in our strategies
#294
untitaker
closed
8 months ago
0
ref: Timestamp is not optional on commit log
#293
lynnagara
closed
8 months ago
0
feat(metrics): Add a metric for number of invalid messages encountered
#292
lynnagara
closed
9 months ago
0
fix(dlq): Gracefully handle case of no valid messages
#291
nikhars
closed
9 months ago
0
ref: A better commit log format pt2
#290
lynnagara
closed
9 months ago
0
ref: A better commit log format
#289
lynnagara
closed
9 months ago
1
Revert "Add coverage report to CI (#286)"
#288
lynnagara
closed
9 months ago
0
feat: Remove pointless (and wrong) config check
#287
lynnagara
closed
9 months ago
1
Add coverage report to CI
#286
dbanda
closed
9 months ago
1
feat: Add supported configuration
#285
lynnagara
closed
9 months ago
1
fix(dlq): Make InvalidMessage pickleable
#284
nikhars
closed
9 months ago
0
fix: Ensure carried over message is in buffer
#283
lynnagara
closed
10 months ago
5
Make producer thread a deamon
#282
dbanda
closed
9 months ago
0
fix(produce): Apply backpressure instead of crashing
#281
lynnagara
closed
10 months ago
0
docs: Actually fix the getting started
#280
lynnagara
closed
10 months ago
0
docs: Fix getting started
#279
lynnagara
closed
10 months ago
0
feat: Add global shutdown handler for strategy factory
#278
untitaker
closed
10 months ago
0
fix(multiprocessing): Make close() call the next steps close()
#277
nikhars
closed
10 months ago
5
fix(run_task_in_threads): Commit offsets even when consumer is idle
#276
untitaker
closed
10 months ago
1
Add socket.timeout.ms to supported kafka configurations
#275
hubertdeng123
closed
11 months ago
0
fix(healthcheck): poll in healthcheck
#274
dbanda
closed
11 months ago
0
Previous
Next