当前位置: 首页 > 知识库问答 >
问题:

KAFKA Connect XML源和JSON接收器

呼延化
2023-03-14

在Kafka中有没有办法使用XML源并将其转换为JSON,然后将JSON数据发送给Kafka进行接收?

我在《Kafka连接》中见过Avro和Protobuf作为转换器?他们能够将XML转换为JSON吗?或者他们会转换为AVRO、Protobuf特定格式而不是JSON?

共有1个答案

丌官晨
2023-03-14

Kafka Connect可以使用任何数据格式。然而,XML没有内置的转换器,所以您只需要使用StringConverter。

然后,您可以使用转换将XML解析为连接使用的内部格式,即结构。例如。https://jcustenborder.github.io/kafka-connect-documentation/projects/kafka-connect-transform-xml/transformations/examples/FromXml.books.html

(显示的json“输入”和“输出”来自REST代理请求,只看值字段)

当写入连接接收器时,您可以使用JSONConverter(或任何其他)来反序列化内部结构对象

 类似资料:
  • 问题内容: 使用Ajax,我试图仅将Json数据发送到节点服务器,不进行任何处理,仅在发送时发出警报,在接收到时发出警报: 这是我的html5:具有onclick函数的简单按钮,可触发该函数使用ajax调用 这是节点服务器的一部分:用于创建服务器并侦听某些操作 没有警报被触发,所以我不认为ajax正在尝试发送信息。 问题答案: 在服务器端尝试此操作: 在客户端: 希望这对你有用

  • 问题内容: 我正在尝试为请求和响应应用程序创建桌面客户端。 我能够轻松地执行GET请求。但是我想知道是否有人可以帮助我确定如何进行JSON请求和响应。并将其解析为字符串,从那里我可以锻炼如何将其全部切开 问题答案: Json.net在.net世界中无处不在。

  • 我正在使用Kafka源和接收器连接器创建一个数据管道。源连接器从SQL数据库消费并发布到主题,而接收器连接器订阅主题并放入其他SQL数据库。表有16 GB的数据。现在的问题是,数据不能从一个数据库传输到另一个数据库。但是,如果表的大小很小,比如1000行,那么数据可以成功传输。 源连接器配置: 源连接器日志: 有人能指导我如何调整Kafka源连接器以传输大数据吗?

  • 本文向大家介绍Spring mvc 接收json对象,包括了Spring mvc 接收json对象的使用技巧和注意事项,需要的朋友参考一下 本文通过代码实例介绍spring mvc 接收json数据的方法,具体详情如下所示: 接收JSON 使用 @RequestBody 注解前台只需要向 Controller 提交一段符合格式的 JSON,Spring 会自动将其拼装成 bean。 1)在上面的项

  • 本文向大家介绍JavaScript 通过POST发送和接收JSON数据,包括了JavaScript 通过POST发送和接收JSON数据的使用技巧和注意事项,需要的朋友参考一下 示例 6 提取请求承诺最初将返回Response对象。它们将提供响应头信息,但它们不直接包含响应主体,而响应主体可能尚未加载。可以使用诸如Response对象上的方法来等待响应主体加载,然后对其进行解析。.json()

  • 我在将JSON从我的前端发送到后端并在那里读取时遇到了一点问题。首先是简单的部分,在我的< code>index.html中,我读取一些字段中写的内容,并将其传递给< code>var inputs “console.log(”input:“JSON.stringify(inputs)”输出到控制台: 输入:{"T_0":"3","E_A":"5"} 这调用函数backend_test该函数应该接