如何从字符串(json)传递模式

bvk5enib 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(420)

我已经为外部rest服务开发了一个自定义源连接器。我得到JSON，把它们转换成 org.apache.kafka.connect.data.Struct 使用手动定义的架构( SchemaBuilder )把这些都包起来 SourceRecord . 所有这些都只针对一个实体，但有十几个实体。
我的新目标是使这个连接器通用化并参数化模式。其思想是从配置或外部文件中获取作为字符串（json）的模式，并将其传递给 SourceRecord ，但它只接受 Schema 物体。
有什么简单/好的方法可以将string/json转换为模式，甚至直接传递string模式吗？

apache-kafka apache-kafka-connect

来源：https://stackoverflow.com/questions/59754583/kafka-source-connector-how-to-pass-the-schema-from-string-json

1条答案

按热度按时间

up9lanfz1#

有一个json到avro的转换器，但是，如果您已经在构建结构/模式组合，那么您不需要做任何事情，因为kafka connect中的转换器类可以为您处理转换
https://www.confluent.io/blog/kafka-connect-deep-dive-converters-serialization-explained/

赞(0）回复(0）举报 2021-06-05

我来回答

如何从字符串(json)传递模式

1条答案

相关问题

热门标签

最新问答