andreaimprovised

**Describe the bug** Retries do not work for the confluent-kafka library as far as I can tell. Seems related to https://github.com/airtai/faststream/issues/1001 in some way. **How to reproduce** Include source code:...

Feature: Unify the middleware interface between Broker and subscriber/publisher

10

**Is your feature request related to a problem? Please describe.** Yes. The API protocol/types for middleware dare different for Broker/Router instantiation vs. subscriber/publisher instantiation. These are the current types in...

Segmentation faults (and the like) and failure to get assignments in multithreaded/asyncio pytest environment

4

Description =========== I have a pytest suite that will: 1. Create a kafka testcontainer as a module fixture 2. Create a bunch of topics as a module fixture using the...

**Is your feature request related to a problem? Please describe.** Yes, I want to know when my confluent Consumer gets topic partitions assigned and removed. Currently, I reach through FastStream...