问答请教大佬们一个问题，我这边刚用chunjun，在使用时写的是sql文件，想在sql中指定参数，比如kafka的地址，然后在使用命令行启动时，可以设置对应的参数，请问这种应该怎么写？网上没有找到案例

请教大佬们一个问题，我这边刚用chunjun，在使用时写的是sql文件，想在sql中指定参数，比如kafka的地址，然后在使用命令行启动时，可以设置对应的参数，请问这种应该怎么写？网上没有找到案例

匿名用户发布于 2023-06-30 18:01 最新回复 2023-06-30 18:02 来自于群内解答 348 2

ChunJun 袋鼠开源袋鼠云开源数据集成数据汇集脏数据处理断点续传大数据采集数据同步传输批流一体

2条回答

群内解答 回复于 2023-06-30 18:02

CREATE TABLE source_test
(
custId STRING,
custCode STRING,
custChName STRING,
custEnName STRING,
certType STRING,
certCode STRING,
dishonestFlag STRING,
updateDate STRING
) WITH (
'connector' = 'kafka-x'
,'topic' = 'topic-test'
,'properties.bootstrap.servers' = '172.1.2.215:8081'
,'properties.group.id' = 'test'
,'scan.startup.mode' = 'earliest-offset'
,'format' = 'json'
,'json.timestamp-format.standard' = 'SQL'
,'scan.parallelism' = '1'
);