kaiju_kafka.streams module

class KafkaConsumer

Bases: Consumer

Stream consumer.

__init__(*args, timeout_ms=1000, max_records=500, **kws)

Initialize.

Parameters:

• timeout_ms (int) –

• max_records (int) –

class KafkaProducer

Bases: Producer

Stream message producer.

async init_topic(topic)

Parameters:

topic (str) –

class KafkaListener

Bases: Listener

Stream service.

service_name = 'streams.kafka'

you may define a custom service name here

consumer_class

alias of KafkaConsumer

producer_class

alias of KafkaProducer

transport_class = None

you should specify your transport class here