我为外部 REST 服务开发了一个自定义源连接器。 我得到 JSON，将它们转换为具有手动定义的模式 (SchemaBuilder( 的org.apache.kafka.connect.data.Struct，并将所有这些包装到SourceRecord中。 所有这些都只针对一个实体，但有十几个。
我的新目标是使此连接器通用化并参数化架构。这个想法是从配置或外部文件中获取模式作为字符串(json(并将其传递给SourceRecord，但它只接受Schema对象。
是否有任何简单/好的方法可以将字符串/json转换为模式，甚至直接传递字符串模式？
有一个JSON到Avro转换器，但是，如果您已经在构建结构/模式组合，那么您不需要做任何事情，因为Kafka Connect中的转换器类可以为您处理转换
https://www.confluent.io/blog/kafka-connect-deep-dive-converters-serialization-explained/