"""Connectors."""

from functools import lru_cache

from confluent_kafka.serialization import StringSerializer
from kafka_utils.producer.event import EventProducer
from kafka_utils.producer.serializer.simple_json import SimpleJSONSerializer

from src import config


@lru_cache(maxsize=None)
def get_producer():
    """Get kafka producer."""
    return EventProducer(
        bootstrap_servers=config.KAFKA_BOOTSTRAP_SERVERS,
        key_serializer=StringSerializer(),
        value_serializer=SimpleJSONSerializer(),
        security_protocol=config.KAFKA_SECURITY_PROTOCOL,
    )