2.1.3 版本routine创建包含jsonpath和jsonroot消费报错

你好,2.1需要修改下语法

"jsonpaths" = "["$.message.opdate","$.message.id","$.message.gps","$.message.opuser","$. message.qrcode","$.message.insertdate"]",

另外$.message中的字段个数和名字是和starrocks中的建表字段个数和名字一致吗?一致的话,按照下面配置也可以

create routine load routine_xxx on xxx
COLUMNS TERMINATED BY “,”
PROPERTIES
(
“format” = “json”,
“desired_concurrent_number”=“1”,
“strict_mode” = “false”,
“max_error_number” = “10000”
)
FROM KAFKA
(
“kafka_broker_list” = “192.168.173.128:9092”,
“kafka_topic” = “xxx”,
“kafka_partitions” = “0”,
“kafka_offsets” = “OFFSET_BEGINNING”
);

是的,后续期望统一用json_path来表达所有的json格式