スキーマ レジストリと Avro を使用して、MongoDB 用のカスタム ソースおよびシンク Kafka コネクタを作成しようとしています。キーと値のコンバーターを AvroConverter として構成し、プロパティでスキーマ レジストリの URL を構成しました。データを Avro に変換し、スキーマに従って検証するには、コネクタにどのコードを追加する必要がありますか?
スキーマ レジストリと Avro を使用して、MongoDB 用のカスタム ソースおよびシンク Kafka コネクタを作成しようとしています。キーと値のコンバーターを AvroConverter として構成し、プロパティでスキーマ レジストリの URL を構成しました。データを Avro に変換し、スキーマに従って検証するには、コネクタにどのコードを追加する必要がありますか?