esgf_core_utils.models.kafka.config

Classes

`KafkaConfig`	Kafka Config
`KafkaConsumerConfig`	Kafka Consumer Config

Module Contents

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

Bases: pydantic.BaseModel

Kafka Config

model_config: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

bootstrap_servers: str = None

sasl_mechanism: str = None

sasl_username: str = None

sasl_password: str = None

security_protocol: str = None

client_id: str = None

class esgf_core_utils.models.kafka.config.KafkaConsumerConfig(/, **data: Any)

Bases: KafkaConfig

Kafka Consumer Config

auto_offset_reset: str = None

enable_auto_commit: bool = None

enable_auto_offset_store: bool = None

group_id: str = None

session_timeout_ms: int = None

debug: str | None = None

log_level: int | None = None