setting use partitioner to True (#122)

faust-streaming · Mar 12, 2021 · 9533e64 · 9533e64
1 parent 54adf90
commit 9533e64
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/faust/stores/aerospike.py b/faust/stores/aerospike.py
@@ -61,6 +61,7 @@ def __init__(
             self.namespace = options.get(self.NAMESPACE_KEY, "")
             self.ttl = options.get(self.TTL_KEY, aerospike.TTL_NEVER_EXPIRE)
             self.policies = options.get(self.POLICIES_KEY, None)
+            table.use_partitioner = True
         except Exception as ex:
             self.logger.error(f"Error configuring aerospike client {ex}")
             raise ex