Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Manually-created changlog topic doesn't allow iteration of keys in table with rocksdb #654

Closed
2 tasks done
g-clef opened this issue Sep 22, 2020 · 0 comments · Fixed by faust-streaming/faust#106 · May be fixed by #655 or trauter/faust#1
Closed
2 tasks done

Comments

@g-clef
Copy link
Contributor

g-clef commented Sep 22, 2020

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)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
1 participant