faust.transport.utils
¶
Transport utils - scheduling.
-
faust.transport.utils.
TopicIndexMap
¶ alias of
typing.MutableMapping
-
class
faust.transport.utils.
DefaultSchedulingStrategy
[source]¶ Consumer record scheduler.
Delivers records in round robin between both topics and partitions.
-
classmethod
map_from_records
(records: Mapping[faust.types.tuples.TP, List]) → MutableMapping[str, faust.transport.utils.TopicBuffer][source]¶ - Return type
-
classmethod