apache-kafka - 如何在 Kafka Source 连接器中使用 Schema Registry 和 AvroConverter？

Question

我正在尝试使用模式注册表和 Avro 为 MongoDB 编写自定义 Source 和 Sink Kafka 连接器。我已将键和值转换器配置为 AvroConverter 和属性中的模式注册表 url。我必须在连接器中添加什么代码才能将数据转换为 Avro 并根据架构进行验证？