Я разработал собственный исходный соединитель для внешней службы REST. Я получаю JSON, преобразую их в org.apache.kafka.connect.data.Struct с определенной вручную схемой (SchemaBuilder) и оборачиваю все это в SourceRecord. Все это только для одного объекта, но их дюжина.
Моя новая цель - сделать этот соединитель универсальным и параметризовать схему. Идея состоит в том, чтобы получить схему в виде String (json) из конфигов или внешних файлов и передать ее SourceRecord, но она принимает только Schema объектов.
Есть ли какие-нибудь простые / хорошие способы преобразовать String / json в схему или даже напрямую передать схему String?