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