我有2 json格式在同一Kafka主题
1.第一个JSON
{
"id": 123,
"name": "name",
"values": [
"one": 1,
"two": 2,
"three": 3,
"four": 4
]
}
1.第二个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"
]
}
我想用单流应用程序对这两个JSON进行一些转换,并在不同的主题中生成输出。是否可以使用单流应用程序?如果可以,那么如何使用?我目前正在使用JAVA进行流应用程序
1条答案
按热度按时间jrcvhitl1#
当然,您可以使用内置的JSON反序列化器将数据作为通用的JsonObject/JsonNode类使用,然后在解析为特定的POJO之前检查过滤器/分支操作符中的特定字段。
或者,您可以使用String Serde,将字符串传递给JSON解析器,然后执行相同的操作。
或者,使用两个不同的主题并根据ID字段连接事件,例如