esgf_core_utils.config.kafka

Classes

KafkaConfig

Kafka Config

KafkaConsumerConfig

Kafka Consumer Config

Module Contents

class esgf_core_utils.config.kafka.KafkaConfig(/, **data: Any)

Bases: pydantic.BaseModel

Kafka Config

class Config
validate_by_name = True
validate_by_alias = True
extra = 'ignore'
bootstrap_servers: str = None
enable_auto_commit: bool = None
sasl_mechanism: str = None
sasl_username: str = None
sasl_password: str = None
security_protocol: str = None
class esgf_core_utils.config.kafka.KafkaConsumerConfig(/, **data: Any)

Bases: KafkaConfig

Kafka Consumer Config

auto_offset_reset: str = None
group_id: str = None
debug: str | None = None
log_level: int | None = None