adding replication factor to the leader topic (#150)

* adding replication factor to the leader topic * fix linting
faust-streaming · May 14, 2021 · 7ab0647 · 7ab0647
1 parent 4500277
commit 7ab0647
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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