Kafka PlaintextProtocol

KafkaPlaintextProtocol

Bases: KafkaProtocol, FrozenModel

Connect to Kafka using PLAINTEXT or SASL_PLAINTEXT security protocols.

Warning

Not recommended to use on production environments. Prefer SSLProtocol.

Added in 0.9.0

Examples:

# No options
protocol = Kafka.PlaintextProtocol()

cleanup(kafka)

This method is called while closing Kafka connection.

Implement it to cleanup resources like temporary files.

Parameters:

• kafka (Kafka) –

  Connection instance

get_options(kafka)

Get options for Kafka connection

Parameters:

• kafka (Kafka) –

  Connection instance

Returns:

• dict ( dict ) –

  Kafka client options