from confluent_kafka import Producer  # type: ignore[import]
from fansifter_common.utils.functional import lazy_proxy

from app.config import settings


def get_kafka_producer() -> Producer:
    return Producer(
        {
            "bootstrap.servers": settings.kafka_bootstrap_servers,
            "security.protocol": settings.kafka_security_protocol,
        }
    )


kafka_producer = lazy_proxy(get_kafka_producer)