Kafka streams API - 反序列化动态生成的 JSON

Question

我一直在尝试找到以下情况的解决方案，但无济于事：

我有一个 Kafka Streams 应用程序，它应该从单个输入主题读取一系列 JSON 对象，所有这些对象彼此不完全相同。实际上，每个 JSON 都是 HTTP 请求对象的表示形式，因此并非所有 JSON 记录都具有相同的标头、请求参数、cookie 等。此外，写入 JSON 对象

有什么办法可以做到这一点吗？不期望任何详细的操作方法解决方案。只是关于我如何实现这一目标的一些线索，因为我在互联网上的搜索到目前为止我一无所获。

Answer 1

这里有一个想法：使用 Jackson 的树模型将 JSON 动态解析为JsonNode，然后在 Kafka Streams 拓扑中使用此树表示来处理请求。

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