"""Avro serializer tests."""

import responses

from kafka_utils.producer.serializer.avro import build_avro_serializer


def test_build_avro_serializer(mock_subject_response):
    """Test build_avro_serializer."""
    with responses.RequestsMock() as rsps:
        rsps.add(
            responses.GET,
            'http://example.com/subjects/event.owsContentReview.review-value/versions/3',
            json=mock_subject_response,
            status=200,
        )
        avro_deserializer = build_avro_serializer(
            'http://example.com',
            'event.owsContentReview.review',
            3,
            config={'use.latest.version': True}
        )
        assert avro_deserializer