我一直在试图找到解决以下情况的办法,但没有结果:
我有一个kafka streams应用程序,它应该从一个输入主题中读取一系列json对象,它们之间并不完全相同。实际上,每个json都是一个http请求对象的表示,因此并非所有json记录都具有相同的头、请求参数、cookies等等。此外,还编写了json对象
有没有办法做到这一点?不希望有任何详细的解决方法。只有一些线索,我如何才能做到这一点,因为我在互联网上的搜索已经结束了我目前什么都没有。
我一直在试图找到解决以下情况的办法,但没有结果:
我有一个kafka streams应用程序,它应该从一个输入主题中读取一系列json对象,它们之间并不完全相同。实际上,每个json都是一个http请求对象的表示,因此并非所有json记录都具有相同的头、请求参数、cookies等等。此外,还编写了json对象
有没有办法做到这一点?不希望有任何详细的解决方法。只有一些线索,我如何才能做到这一点,因为我在互联网上的搜索已经结束了我目前什么都没有。
1条答案
按热度按时间41ik7eoe1#
这里有一个想法:使用jackson的树模型将json动态解析为
JsonNode
,然后在kafka streams拓扑中使用此树表示来处理请求。