tethys.core.transports.connectors.connector_kafka

Module Contents

class tethys.core.transports.connectors.connector_kafka.KafkaConnection(channel_id: str, group_id: str, partition: int, bootstrap_servers: list, producer_params: dict, consumer_params: dict)

Bases: tethys.core.transports.connectors.connector_base.ConnectionBase

Helper class that provides a standard way to create an ABC using inheritance.

Initialize self. See help(type(self)) for accurate signature.

recv_iter(self, **kwargs)

send(self, data_packet, **kwargs)

ack(self, message_key, **kwargs)

open(self, **kwargs) → 'KafkaConnection'

close(self, **kwargs) → 'KafkaConnection'

class tethys.core.transports.connectors.connector_kafka.KafkaConnector(partition: int = 0, bootstrap_servers: list = None, producer_params: dict = None, consumer_params: dict = None)

Bases: tethys.core.transports.connectors.connector_base.ConnectorBase

Initialize self. See help(type(self)) for accurate signature.

connect(self, channel_id: str, group_id: str = None, partition: int = 0, bootstrap_servers: list = None, producer_params: dict = None, consumer_params: dict = None, **kwargs) → 'KafkaConnection'