diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py
index 17e8a9ef8..9507afc62 100644
--- a/faust/stores/rocksdb.py
+++ b/faust/stores/rocksdb.py
@@ -453,7 +453,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)
             # for global tables, keys from all
diff --git a/tests/unit/stores/test_rocksdb.py b/tests/unit/stores/test_rocksdb.py
index b4907898a..8041922e6 100644
--- a/tests/unit/stores/test_rocksdb.py
+++ b/tests/unit/stores/test_rocksdb.py
@@ -427,7 +427,7 @@ def test__dbs_for_key(self, *, store):
         assert list(store._dbs_for_key(b"key")) == [dbs[2]]
 
     def test__dbs_for_actives(self, *, store, table):
-        table._changelog_topic_name.return_value = "clog"
+        table.changelog_topic_name = "clog"
         store.app.assignor.assigned_actives = Mock(
             return_value=[
                 TP("clog", 1),