Checklist

• I have included information about relevant versions
• I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

Create changlog topic manually, make Table from that using rocksdb store, add data to the Table, try to iterate over the keys in the table.

Expected behavior

Iteration over the Table as a dict should allow access to all the keys assigned to the node for that table.

Actual behavior

No keys are returned. This is because in stores/rocksdb.py the _dbs_for_actives method looks at self.table._changelog_table_name() , which returns the auto-generated topic name for the changelog, rather than the actually-assigned topic name.

Versions

• Python version 3.7
• Faust version 1.10.4
• Operating system Linux
• Kafka version
• RocksDB version (if applicable)