从 Kafka 到 Druid 的交互式实时更新数据

如何解决从 Kafka 到 Druid 的交互式实时更新数据

我是使用 druid 和 kafka 的初学者。

案例是我想通过实时更新将数据从 kafka 上传到德鲁伊， 当我想将任何新数据上传到 kafka 时，德鲁伊会自动更新其数据。 我假设我的配置有错误或在德鲁伊中丢失。

这是我的德鲁伊配置。

{
  "type": "kafka","spec": {
    "ioConfig": {
      "type": "kafka","consumerProperties": {
        "bootstrap.servers": "localhost:9092"
      },"topic": "testing1","inputFormat": {
        "type": "json"
      },"useEarliestOffset": true
    },"tuningConfig": {
      "type": "kafka"
    },"dataSchema": {
      "dataSource": "testing1","timestampSpec": {
        "column": "tanggal","format": "iso"
      },"dimensionsspec": {
        "dimensions": [
          {
            "type": "long","name": "jumlah_pembelian"
          },"kode_cabang","kode_item","kode_kasir","kode_produk"
        ]
      },"granularitySpec": {
        "queryGranularity": "none","rollup": false,"segmentGranularity": "year"
      }
    }
  }
}

有人知道我该怎么做吗？