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: