We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c87358d commit 8a4c60bCopy full SHA for 8a4c60b
faststream/confluent/broker/registrator.py
@@ -115,7 +115,7 @@ def subscriber(
115
partitions: Sequence["TopicPartition"] = (),
116
polling_interval: float = 0.1,
117
group_id: str | None = None,
118
- group_instance_id: None = None,
+ group_instance_id: str | None = None,
119
fetch_max_wait_ms: int = 500,
120
fetch_max_bytes: int = 50 * 1024 * 1024,
121
fetch_min_bytes: int = 1,
0 commit comments