Add middleware for xkafka.BatchConsumer#61

Open

sonnes wants to merge 4 commits intoxkafka/batchfrom xkafka/batch-middleware

+283-31

Commits on Jan 8, 2025

Add BatchRecoverMiddleware for handling panics in batch processing
Ravi Atluri
committed
Add BatchExponentialBackoff middleware and corresponding tests for batch processing with exponential backoff retry strategy
Ravi Atluri
committed
Add xpromkafka.BatchConsumerMiddleware and corresponding tests for batch processing metrics and error handling
Ravi Atluri
committed
Fix flaky test TestBatchConsumer_StopOffsetOnError; add deferred cancel in runAsync for graceful shutdown
Ravi Atluri
committed