"""Publish event logic."""

from src import config
from src import kafka_connector


def publish_audio_infringements_event(matches):
    """Publish the audio infringements events."""
    for match in matches:
        kafka_connector.get_producer().produce(
            topic=config.KAFKA_AUDIO_INFRINGEMENTS_TOPIC,
            event_key=f'asset_final_id_{match["asset_final_id"]}',
            event_value=match
        )