faust.tables.manager
¶
Tables (changelog stream).
-
class
faust.tables.manager.
TableManager
(app: faust.types.app.AppT, **kwargs) → None[source]¶ Manage tables used by Faust worker.
-
persist_offset_on_commit
(store: faust.types.stores.StoreT, tp: faust.types.tuples.TP, offset: int) → None[source]¶ Mark the persisted offset for a TP to be saved on commit.
This is used for “exactly_once” processing guarantee. Instead of writing the persisted offset to RocksDB when the message is sent, we write it to disk when the offset is committed.
- Return type
None
-
changelog_queue
¶ - Return type
-
logger
= <Logger faust.tables.manager (WARNING)>¶
-
coroutine
on_rebalance
(self, assigned: Set[faust.types.tuples.TP], revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]¶ - Return type
None
-