【详述】文档中demo按步骤操作失败,文档地址
1.以下为mysql表结构
2.以下为starrocks表结构
3.以下为canal读取binlog后存入kafka指定topic=testtopic的数据
4.routine loader 语句
create routine load test.lcytest on lcytest
columns (id, name, age, gender)
PROPERTIES (
"format"="json",
"json_root"="$.data",
"desired_concurrent_number"="1",
"strip_outer_array" ="true",
"max_error_number"="0"
)
FROM KAFKA (
"kafka_broker_list"= "192.168.44.4:9092,192.168.44.5:9092,192.168.44.6:9092",
"kafka_topic" = "testtopic"
);
5.查询starrocks表并未发现有数据,mysql执行insert后也没有数据,starrocks查看show routine load 也未报错