小编Ult*_*ine的帖子

具有变量嵌套 JSON 对象作为 KSQL DB 流的 Kafka 主题

我正在尝试加入 KSQL 中的两个现有 Kafka 主题。Kafka的一些数据样本(实际值因企业环境有所删减):

设备主题:

{
  "persistTime" : "2020-10-06T13:30:25.373Z",
  "previous" : {
    "device" : "REDACTED",
    "type" : "REDACTED",
    "group" : "REDACTED",
    "inventoryState" : "unknown",
    "managementState" : "registered",
    "communicationId" : "REDACTED",
    "manufacturer" : "",
    "description" : "",
    "model" : "",
    "location" : {
      "geo" : {
        "latitude" : "REDACTED",
        "longitude" : "REDACTED"
      },
      "address" : {
        "city" : "",
        "postalCode" : "",
        "street" : "",
        "houseNumber" : "",
        "floor" : "",
        "company" : "",
        "country" : "",
        "reference" : "", …
Run Code Online (Sandbox Code Playgroud)

apache-kafka ksqldb

3
推荐指数
1
解决办法
3319
查看次数

标签 统计

apache-kafka ×1

ksqldb ×1