from addict import Dict

KAFKA = Dict({
    "bootstrap_servers": ["81.68.220.135:9092"],
    "enable_auto_commit": True,
    "auto_commit_interval_ms": 3000,
    "consumer_timeout_ms": float('inf'),
    "auto_offset_reset": "earliest",
    "default_group_id": "etl_",
    "customers": [],
})

SQLARCHEMY = Dict({
    "database":
    "mysql+mysqlconnector://root:liando@140.143.35.79:8886/power_oa",
    "pool": 5,
    "max_overflow": 10,
    "pool_timeout": 30,
    "pool_pre_ping": True
})
