登録されたスキーマをID /件名でコネクタで取得する

Question

登録されたスキーマをソースコネクタで取得することは可能ですか？私はスキーマレジストリに登録された静的スキーマを持っており、そのスキーマをコネクタから取得してSourceRecordに渡す必要があります。

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

または他の方法で私はCachedSchemaRegistryClientを使って同じことを直接行うことができますか？

は、あなたが検索を行うには、スキーマレジストリに残り電話をかけることができ、 Sreejith

Answer 1

をありがとうございました。しかし、これはコネクタの非常に非標準的な使用です。この種のルックアップをコンバータで行う方が良いかもしれません。