0

ソース コネクタで登録済みのスキーマを取得することはできますか? スキーマ レジストリに登録されている静的スキーマがあり、そのスキーマをコネクタから取得して SourceRecord に渡す必要があります。

schema id を使用してスキーマを取得するために CachedSchemaRegistryClient を使用しましたが、Avro スキーマが返されました。したがって、これを org.apache.kafka.connect.data.Schema に変換する必要があります。これに関するいくつかの指針を提供してください。

または、 CachedSchemaRegistryClient を使用せずに直接同じことができるコネクタの他の方法はありますか?

ありがとう、スリージット

4

1 に答える 1

0

ルックアップを行うために、スキーマ レジストリへの残りの呼び出しを行うことができます。ただし、これはコネクタの非常に非標準的な使用法です。コンバーターでこの種のルックアップを行う方がよい場合があります。

于 2016-10-01T17:14:43.697 に答える