faust.transport.producer
¶
Producer.
The Producer is responsible for:
Holds reference to the transport that created it
… and the app via
self.transport.app
.Sending messages.
-
class
faust.transport.producer.
Producer
(transport: faust.types.transports.TransportT, loop: asyncio.events.AbstractEventLoop = None, **kwargs) → None[source]¶ Base Producer.
-
key_partition
(topic: str, key: bytes) → faust.types.tuples.TP[source]¶ Hash key to determine partition.
- Return type
-
logger
= <Logger faust.transport.producer (WARNING)>¶
-