2.11.7

Various fixes & improvements

• feat: Avoid spinning on MessageRejected (#253) by @lynnagara

2.11.6

Various fixes & improvements

• feat: Basic support for librdkafka stats (#252) by @untitaker

2.11.5

Various fixes & improvements

• add entries to list (#250) by @ayirr7
• ref(multiprocessing): Rename some metrics and add documentation (#241) by @untitaker
• feat(metrics): Allow reconfiguring the metrics backend (#249) by @lynnagara
• ref: Global metrics registry (#245) by @untitaker

2.11.4

Various fixes & improvements

• fix: Fix run task in threads (again) (#244) by @lynnagara

2.11.3

Various fixes & improvements

• fix(run-task-in-threads): Fix shutdown (#243) by @lynnagara
• fix: Mermaid diagrams in dark mode (#242) by @untitaker

2.11.2

Various fixes & improvements

• Revert "feat: add more item size stats to multiprocessing (and metrics refactor) (#235)" (#240) by @untitaker
• fix(multiprocessing): More performant backpressure [INC-378] (#238) by @untitaker
• fix(multiprocessing): Honor join() timeout even if processing pool is overloaded [INC-378] (#237) by @untitaker
• docs: Minor readability details (#236) by @kamilogorek
• feat: add more item size stats to multiprocessing (and metrics refactor) (#235) by @untitaker

2.11.1

Various fixes & improvements

• fix: Distinguish between backpressure and output overflow (#234) by @untitaker

2.11.0

Various fixes & improvements

• perf(dlq): Improve performance when there are many invalid messages (#233) by @lynnagara

2.10.6

Various fixes & improvements

• chore(processor): More logs for shutdown sequences (#230) by @nikhars
• fix: Remove flaky test (#232) by @untitaker
• fix: Do not log error when consumer is already crashing (#228) by @untitaker

2.10.5

Various fixes & improvements

• fix(run_task_with_multiprocessing): Do not attempt to skip over invalid messages (#231) by @untitaker