Kafka Auth

class onetl.connection.db_connection.kafka.kafka_auth.KafkaAuth

Interface for Kafka connection Auth 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