diff --git a/faststream/kafka/subscriber/usecase.py b/faststream/kafka/subscriber/usecase.py index 5af13fdd8b..7b0f34b76a 100644 --- a/faststream/kafka/subscriber/usecase.py +++ b/faststream/kafka/subscriber/usecase.py @@ -267,6 +267,7 @@ def __init__( group_id: Optional[str], listener: Optional["ConsumerRebalanceListener"], pattern: Optional[str], + partitions: Optional[Iterable["TopicPartition"]], builder: Callable[..., "AIOKafkaConsumer"], is_manual: bool, # Subscriber args @@ -284,6 +285,7 @@ def __init__( group_id=group_id, listener=listener, pattern=pattern, + partitions=partitions, builder=builder, is_manual=is_manual, # subscriber args @@ -315,6 +317,7 @@ def __init__( group_id: Optional[str], listener: Optional["ConsumerRebalanceListener"], pattern: Optional[str], + partitions: Optional[Iterable["TopicPartition"]], builder: Callable[..., "AIOKafkaConsumer"], is_manual: bool, # Subscriber args @@ -337,6 +340,7 @@ def __init__( group_id=group_id, listener=listener, pattern=pattern, + partitions=partitions, builder=builder, is_manual=is_manual, # subscriber args