通过连接器中的id/主题获取注册的模式

e1xvtsh3  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(242)

是否可以从源连接器中获取注册的架构?我在schema registry中注册了一个静态模式,需要从connector获取该模式并将其传递给sourcerecord。
我使用cachedschemaregistryclient使用schema id获取模式,但它返回了一个avro模式。所以我必须把它转换成org.apache.kafka.connect.data.schema。请提供一些这方面的建议。
或者在连接器中的任何其他方式,我可以直接使用cachedschemaregistryclient执行相同的操作?
谢谢你,斯雷吉思

mtb9vblg

mtb9vblg1#

您可以对模式注册表进行rest调用来执行查找。然而,这是一个相当不标准的连接器使用。您最好在转换器中执行这种查找。

相关问题