From 56ee814b9330a9df86c99aa9ab965a864f00beb1 Mon Sep 17 00:00:00 2001 From: alexanderoberegger Date: Thu, 8 Oct 2020 17:14:59 +0200 Subject: [PATCH] adjusted changelog topic name as proposed in slack channel --- faust/stores/rocksdb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py index b073a25dd..c70c8ea60 100644 --- a/faust/stores/rocksdb.py +++ b/faust/stores/rocksdb.py @@ -388,7 +388,7 @@ def _dbs_for_key(self, key: bytes) -> Iterable[DB]: def _dbs_for_actives(self) -> Iterator[DB]: actives = self.app.assignor.assigned_actives() - topic = self.table._changelog_topic_name() + topic = self.table.changelog_topic_name for partition, db in self._dbs.items(): tp = TP(topic=topic, partition=partition) if tp in actives: