是否可以从源连接器中获取注册的架构?我在schema registry中注册了一个静态模式,需要从connector获取该模式并将其传递给sourcerecord。
我使用cachedschemaregistryclient使用schema id获取模式,但它返回了一个avro模式。所以我必须把它转换成org.apache.kafka.connect.data.schema。请提供一些这方面的建议。
或者在连接器中的任何其他方式,我可以直接使用cachedschemaregistryclient执行相同的操作?
谢谢你,斯雷吉思
1条答案
按热度按时间mtb9vblg1#
您可以对模式注册表进行rest调用来执行查找。然而,这是一个相当不标准的连接器使用。您最好在转换器中执行这种查找。