Introduce max_concurrent_consumed_messages: stop reading when threshold is reached on slow consumer callbacks
#342
| Job | Run time |
|---|---|
| 13s | |
| 1m 2s | |
| 19s | |
| 49s | |
| 1m 16s | |
| 3m 39s |