clickhouse ：无法解析 JSON 字符串：预期的开头引用：同时读取关键数据的值：在第 1 行：执行 SourceFromInputStream

问题描述

这个错误信息：

SELECT *
FROM queue2
Received exception from server (version 20.9.3):
Code: 26. DB::Exception: Received from xxxx:xxxx. DB::Exception: Cannot parse JSON string: expected opening quote: (while read the value of key data): (at row 1)
: While executing SourceFromInputStream.

我创建了一个 kafka 表来从 kafka 主题中获取数据，这是数据结构：

{
  "deviceid": 0,"data": [
    {
      "port_id": "2137","time":1617103821,"in":200.5496688741722,"out":319.4801324503311
    }
  ]
}

这是卡夫卡表：

CREATE TABLE queue 
(
    deviceid Int8,data nested(
    port_id String,time Int64,    in Float32,    out Float32)
) 
ENGINE = Kafka 
SETTINGS kafka_broker_list = 'xxx,xxx,xxx',kafka_topic_list = 'librenms_flow',kafka_group_name = 'niop-billing-test-group',kafka_format = 'JSONEachRow',kafka_num_consumers = 1;

创建 kafka 表和 MATERIALIZED VIEW 应该怎么做？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

apache-kafka clickhouse