通過ID /主題獲取已註冊的模式連接器

Question

是否可以從源連接器中獲取已註冊的模式？我有一個在模式註冊表中註冊的靜態模式，需要從連接器獲取該模式並將其傳遞給SourceRecord。

我使用CachedSchemaRegistryClient獲取使用模式ID的模式，但它返回了Avro模式。所以我必須將其轉換爲org.apache.kafka.connect.data.Schema。請提供一些指示。

或者連接器中的任何其他方式，我可以使用CachedSchemaRegistryClient直接執行相同的操作？

謝謝你， Sreejith

Answer 1

你可以做一個REST調用到架構註冊表做查找。然而，這是一個非常不標準的連接器使用。在轉換器中進行這種查找可能會更好。