我们可以在Apache Kafka中使用单流应用程序从单个主题处理多个Json格式吗

Question

我在同一个kafka主题中有两个json格式

1. 第一个JSON

{
"id": 123,
"name": "name",
"values": [
"one": 1,
"two": 2,
"three": 3,
"four": 4
]
}

2. 第二个JSON

{
"id": 8,
"title": "Microsoft Surface Laptop 4",
"description": "Style and speed. Stand out on ...",
"price": 1499,
"discountPercentage": 10.23,
"rating": 4.43,
"stock": 68,
"brand": "Microsoft Surface",
"category": "laptops",
"thumbnail": "https://dummyjson.com/image/i/products/8/thumbnail.jpg",
"images": [
"https://dummyjson.com/image/i/products/8/1.jpg",
"https://dummyjson.com/image/i/products/8/2.jpg",
"https://dummyjson.com/image/i/products/8/3.jpg",
"https://dummyjson.com/image/i/products/8/4.jpg",
"https://dummyjson.com/image/i/products/8/thumbnail.jpg"
]
}

我想用一个Stream应用程序对这两个JSON执行一些转换，并在不同的主题中生成输出。是否可以使用单流应用程序？如果是，那么怎么做呢？我目前正在使用JAVA进行流应用

Answer 1

当然，您可以使用内置的JSON反序列化程序将数据作为通用JsonObject/JsonNode类使用，然后在解析到特定POJO之前检查过滤器/分支运算符中的特定字段。

或者，您可以使用StringSerde，将字符串传递给JSON解析器，并执行同样的操作。

或者，使用两个不同的主题并根据ID字段加入事件，例如