Change RocksDB to check the assigned topic name

robinhood / faust

Python Stream Processing

Other

6.72k stars 535 forks source link

Change RocksDB to check the assigned topic name #655

Open g-clef opened 3 years ago

g-clef commented 3 years ago

Description

Changes the RocksDB store to check the assigned topic name for a changelog, rather than the auto-generated one. If the changelog uses a manually-created topic, using the auto-generated name causes keys(), values(), items() on the Table object that this store backs to return no data, since the changelog names never match.

Resolves #654

CLAassistant commented 3 years ago

All committers have signed the CLA.