反序列化动态生成的json

gr8qqesn  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(329)

我一直在试图找到解决以下情况的办法,但没有结果:
我有一个kafka streams应用程序,它应该从一个输入主题中读取一系列json对象,它们之间并不完全相同。实际上,每个json都是一个http请求对象的表示,因此并非所有json记录都具有相同的头、请求参数、cookies等等。此外,还编写了json对象
有没有办法做到这一点?不希望有任何详细的解决方法。只有一些线索,我如何才能做到这一点,因为我在互联网上的搜索已经结束了我目前什么都没有。

41ik7eoe

41ik7eoe1#

这里有一个想法:使用jackson的树模型将json动态解析为 JsonNode ,然后在kafka streams拓扑中使用此树表示来处理请求。

ObjectMapper objectMapper = new ObjectMapper();
JsonNode rootNode = objectMapper.readTree(json);
...

相关问题