Kafka Protocol

class onetl.connection.db_connection.kafka.kafka_protocol.KafkaProtocol

Interface for Kafka connection Protocol classes.

abstract get_options(kafka: Kafka) → dict

Get options for Kafka connection

Parameters:

kafkaKafka

Connection instance

Returns:

dict:

Kafka client options

abstract cleanup(kafka: Kafka) → None

This method is called while closing Kafka connection.

Implement it to cleanup resources like temporary files.

Parameters:

kafkaKafka

Connection instance