"""Example avro message consumer."""

from helpers import debug_msk_message
from helpers import load_file_json

from kafka_utils.consumer.deserializer.avro import AvroDeserializer
from kafka_utils.consumer.deserializer.string import StringDeserializer
from kafka_utils.consumer.source.mapping import EventSourceMessage

SCHEMA_REGISTRY_URL = 'https://dev-schema-registry.dev.theorchard.io'
TOPIC_NAME = 'event.owsContentReview.review'
EVENT_JSON = load_file_json('product_review.json')


def main():
    """Process message."""
    string_deserializer = StringDeserializer()
    avro_deserializer = AvroDeserializer(SCHEMA_REGISTRY_URL)
    event = EventSourceMessage(EVENT_JSON)
    for batch_key, msk_message in event:
        debug_msk_message(
            batch_key,
            msk_message,
            key_deserializer=string_deserializer,
            value_deserializer=avro_deserializer)


if __name__ == '__main__':
    main()