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

Question

我一直在尝试解决以下情况，但无济于事：

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

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

Answer 1

这是一个想法：使用 Jackson's tree model 将您的 JSON 动态解析为 JsonNode，然后在您的 Kafka Streams 拓扑中使用此树表示来处理请求。

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