faust.transport.drivers.aiokafka

Message transport using aiokafka.

class faust.transport.drivers.aiokafka.Consumer(*args, **kwargs) → None

Kafka consumer using aiokafka.

logger = <Logger faust.transport.drivers.aiokafka (WARNING)>

RebalanceListener

alias of ConsumerRebalanceListener

consumer_stopped_errors = (<class 'aiokafka.errors.ConsumerStoppedError'>,)

class faust.transport.drivers.aiokafka.Producer(transport: faust.types.transports.TransportT, loop: asyncio.events.AbstractEventLoop = None, **kwargs) → None

Kafka producer using aiokafka.

logger = <Logger faust.transport.drivers.aiokafka (WARNING)>

allow_headers = True

key_partition(topic: str, key: bytes) → faust.types.tuples.TP

Hash key to determine partition destination.

Return type

TP

supports_headers() → bool

Return True if message headers are supported.

Return type

bool

class faust.transport.drivers.aiokafka.Transport(*args, **kwargs) → None

Kafka transport using aiokafka.

class Consumer(*args, **kwargs) → None

Kafka consumer using aiokafka.

RebalanceListener

alias of ConsumerRebalanceListener

consumer_stopped_errors = (<class 'aiokafka.errors.ConsumerStoppedError'>,)

logger = <Logger faust.transport.drivers.aiokafka (WARNING)>

class Producer(transport: faust.types.transports.TransportT, loop: asyncio.events.AbstractEventLoop = None, **kwargs) → None

Kafka producer using aiokafka.

allow_headers = True

key_partition(topic: str, key: bytes) → faust.types.tuples.TP

Hash key to determine partition destination.

Return type

TP

logger = <Logger faust.transport.drivers.aiokafka (WARNING)>

supports_headers() → bool

Return True if message headers are supported.

Return type

bool

default_port = 9092

driver_version = 'aiokafka=1.0.3'