1,routine load 创建语句如下，最后在 kafka 中看到的消费者组名称为 ip+uuid，也不是文档中写的{job_name}_{random uuid}
CREATE ROUTINE LOAD ods_terminal_platform_tb_merchant_terminal_bind_job ON ods_terminal_platform_tb_merchant_terminal_bind
COLUMNS
(
id ,
terminal_id ,
terminal_alias ,
bind_merchant_no ,
custom_config ,
status ,
create_time ,
update_time ,
shop_id
)
PROPERTIES
(
“desired_concurrent_number”=“3”,
“format” = “json”,
“max_error_number”=“20000”,
“max_batch_interval”=“5”,
“jsonpaths” = "
[
“$.after.id”,
“$.after.terminal_id”,
“$.after.terminal_alias”,
“$.after.bind_merchant_no”,
“$.after.custom_config”,
“$.after.status”,
“$.after.create_time”,
“$.after.update_time”,
“$.after.shop_id”
]
"
)
FROM KAFKA
(
“kafka_broker_list”= “xxx:9092”,
“kafka_topic” = “TERMINAL_PLATFORM_TB_MERCHANT_TERMINAL_BIND”,
“property.kafka_default_offsets” = “OFFSET_BEGINNING”,
“property.group.id” = “TERMINAL_PLATFORM_TB_MERCHANT_TERMINAL_BIND_GROUP”
);"