Kafka Protocol

Bases: ABC

Interface for Kafka connection Protocol classes.

Added in 0.9.0

cleanup(kafka) abstractmethod

This method is called while closing Kafka connection.

Implement it to cleanup resources like temporary files.

Parameters:

• kafka (Kafka) –

  Connection instance

get_options(kafka) abstractmethod

Get options for Kafka connection

Parameters:

• kafka (Kafka) –

  Connection instance

Returns:

• dict ( dict ) –

  Kafka client options