KafkaClients

class safir.metrics.KafkaClients(broker, admin_client)

Bases: object

Kafka clients that an EventManager should use.

Parameters:

• broker (KafkaBroker)

• admin_client (AIOKafkaAdminClient)