从一个主题使用XML，转换为JSON并将其发送到另一个主题
我的任务是编写一个java程序，从一个主题中读取xml，将其转换为JSON并发送到另一个主题。我已经创建了一个将xml转换为json的程序，但我不知道接下来该怎么做，比如如何使用该主题中的xml并将其发送给另一个主题。
共有1个答案
你可以使用KStreams
java prettyprint-override">KStream<String, String> kstream = builder.stream("xml-topic",
Consumed.with(Serdes.String(), Serdes.String()));
kstream
.mapValues(xmlData -> convertXMLToJSON(xmlData)) // call your function
.to("json-topic", Produced.with(Serdes.String(), Serdes.String()));
-
我有一个来自Kafka主题的大型json，我正在将其转换为Java对象，以提取find DB中所需的值。一些记录中会有一系列缺陷，我需要捕获这些缺陷并将其发送到不同的主题，这样它们就可以在数据库中自己的表中结束。使用接收器连接器将值插入数据库，这就是为什么我们使用多个主题。 我发现了分支和拆分，但这似乎更适合于确定一条已消费的记录应该转到哪个主题，而不是将记录的不同部分发送到不同的主题。有没有办法
-
我正在使用spark streaming文档中提供的策略来致力于Kafka本身。我的流程是这样的：主题A-->火花流[foreachRdd process->send to Topic b]向主题A提交偏移量
-
在设置到数据库的连接时出现，并在服务器上的日志文件夹中查看文件error_log，我看到。 谁能告诉我，我是否遗漏了一些必要的步骤，或者问题出在哪里？
-
我有下面的JSON输入，我想删除值标签并在TypeOfSTA中设置标题值。 我想使用JOLT转换在输出JSON中进行转换。 下面是我的请求JSON和输出JSON。 请求 JSON： 请帮助我使用JOLT转换进行转换。 输出JSON：
-
问题内容： 我有一个JSP文件为 jsp 1.jsp ，另一个JSP文件为 jsp 2.jsp 我已经包括 JSP 2.jsp 在 JSP 1.jsp页面 使用 现在，我需要某些元素上的click事件。在那件事上，我想将一个字符串变量传递给包含的jsp。 假设我有一个列表，单击它后，我想将该列表的名称转移到另一个JSP， 在另一个JSP中，我试图使用该字符串执行某些任务。 我在没有任何servle
-
你好stackoverflow我正在寻找帮助来解决我在使用XML文件时遇到的逻辑问题。上面的代码创建了一个带有“演讲者”名称的文件，然后它应该将演讲者所说的内容放入该文件中。 我遇到的问题是，它将所有扬声器放在同一个文件中。所以我认为问题就在这里： 我希望有人有更好的方法来做到这一点，但想法是将上述代码更改为： 最终，我希望每个演讲者都在自己的XML文件中包含自己的演讲。 以上是XML文件中的一个