kafka_settings.py

from typing import Dict, Any  
  
from pydantic import Field  
  
from sitri.settings.contrib.vault import VaultKVSettings  
  
from superapp.config.provider_config import provider, configurator  
  
  
class KafkaSettings(VaultKVSettings):  
    auth_mechanism: str = Field(...)  
    brokers: str = Field(...)  
    auth_data: Dict[str, Any] = Field(...)  
  
    class Config:  
        provider = provider  
        default_secret_path = "kafka"  
        default_mount_point = f"{configurator.get('app_name')}/common"