diff --git a/faust/assignor/leader_assignor.py b/faust/assignor/leader_assignor.py index 2b891921e..535667250 100644 --- a/faust/assignor/leader_assignor.py +++ b/faust/assignor/leader_assignor.py @@ -34,6 +34,7 @@ def _leader_topic(self) -> TopicT: partitions=1, acks=False, internal=True, + replicas=self.app.conf.topic_replication_factor, ) @cached_property