Kafka BasicAuth

pydantic model onetl.connection.db_connection.kafka.kafka_basic_auth.KafkaBasicAuth

Connect to Kafka using sasl.mechanism="PLAIN".

For more details see Kafka Documentation.

Examples

Auth in Kafka with user and password:

from onetl.connection import Kafka

auth = Kafka.BasicAuth(
    user="some_user",
    password="abc",
)

field user: str [Required] (alias 'username')

field password: SecretStr [Required]

get_jaas_conf() → str

get_options(kafka: Kafka) → dict

Get options for Kafka connection

Parameters:

kafkaKafka

Connection instance

Returns:

dict:

Kafka client options

cleanup(kafka: Kafka) → None

This method is called while closing Kafka connection.

Implement it to cleanup resources like temporary files.

Parameters:

kafkaKafka

Connection instance