Kafka PlaintextProtocol

pydantic model onetl.connection.db_connection.kafka.kafka_plaintext_protocol.KafkaPlaintextProtocol

Connect to Kafka using PLAINTEXT or SASL_PLAINTEXT security protocols.

Warning

Not recommended to use on production environments. Prefer SSLProtocol.

Examples

# No options
protocol = Kafka.PlaintextProtocol()

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