esgf_core_utils.models.kafka.consumer

Classes

KafkaConsumer

Kafka consumer

Module Contents

class esgf_core_utils.models.kafka.consumer.KafkaConsumer(message_processor: esgf_core_utils.models.kafka.message_processor.MessageProcessor)

Kafka consumer

settings

message_processor

consumer

start() → None

Start consuming messages