Kafka Protocol

KafkaProtocol

Interface for Kafka connection Protocol classes.

Added in 0.9.0

get_options(kafka)

Get options for Kafka connection

Parameters:

• kafka

  (Kafka) –

  Connection instance

Returns:

• dict –

  Kafka client options

cleanup(kafka)

This method is called while closing Kafka connection.

Implement it to cleanup resources like temporary files.

Parameters:

• kafka

  (Kafka) –

  Connection instance