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

w1jd8yoj  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(137)

我有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进行流应用程序

jrcvhitl

jrcvhitl1#

当然,您可以使用内置的JSON反序列化器将数据作为通用的JsonObject/JsonNode类使用,然后在解析为特定的POJO之前检查过滤器/分支操作符中的特定字段。
或者,您可以使用String Serde,将字符串传递给JSON解析器,然后执行相同的操作。
或者,使用两个不同的主题并根据ID字段连接事件,例如

相关问题