我有一个python rest服务，它接收包含avro模式定义和有效负载的请求。服务需要验证有效负载是否与提供的模式匹配。如果有效，则将消息写入Kafka主题。如果无效，则返回错误消息。
我正在使用avro.io.validate方法来确定有效负载是否有效。这是可行的，但它并没有向我提供有用的错误消息。我发现最好的方法是返回有效负载和模式，并告诉调用者数据无效。我想为他们提供一个更有用的错误消息。
应用程序中的大多数avro/kafka工作都使用合流的kafka库，但是我找不到一个好的方法来验证它们。如果我在合流库中遗漏了一些东西，我很乐意尝试，否则我会觉得我在使用avro.io validate方法，或者我自己的方法。
任何建议都会有帮助。