diff --git a/faust/stores/rocksdb.py b/faust/stores/rocksdb.py
index a414d7bcd..a3de5f332 100644
--- a/faust/stores/rocksdb.py
+++ b/faust/stores/rocksdb.py
@@ -393,7 +393,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/t/unit/stores/test_rocksdb.py b/t/unit/stores/test_rocksdb.py
index cf81b8bc2..735771226 100644
--- a/t/unit/stores/test_rocksdb.py
+++ b/t/unit/stores/test_rocksdb.py
@@ -422,7 +422,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),
             TP('clog', 2),