def METHOD_NAME(log, producer):
    try:
        producer.produce_message(log)
    except Exception as e:
        logger.info(f'Error gathering the file or producing to Kafka: {str(e)}')
        raise e