У меня есть служба REST python, которая получает запросы, содержащие определение схемы Avro и полезную нагрузку. Служба должна проверить, что полезная нагрузка соответствует предоставленной схеме. Если он действителен, он пишет сообщение в тему Кафки. Если он недействителен, он возвращает сообщение об ошибке.
Я использую метод avro.io.validate для определения допустимости полезной нагрузки. Это работает, но не дает мне полезного сообщения об ошибке. Лучшее, что я понял, - это вернуть полезную нагрузку и схему и сообщить вызывающей стороне, что данные недействительны. Я хотел бы предоставить им более полезное сообщение об ошибке.
Большая часть работы Avro / Kafka в приложении использует библиотеки Confluent Kafka, но я не смог найти хороший способ проверки с ними. Если есть что-то, что я пропустил в библиотеках Confluent, я играю, чтобы попробовать это, иначе я чувствую, что застрял, используя метод проверки avro.io, или бросил свой собственный.
Любые предложения будут полезны.