检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单击右上角“启动”，进入“启动Flink作业”页面。 在“启动Flink作业”页面确认作业规格和费用，单击“立即启动”，启动作业。 启动作业后，系统将自动跳转到Flink作业管理页面，在“状态”列中可以查看作业状态。 作业提交成功后，状态将由“提交中”变为“运行中”。运行完成后显示“已完成”。
业”。 在创建队列界面，类型选择“Flink OpenSource SQL”，名称填写为：FlinkCDCMySQLDWS。单击“确定”，跳转到Flink作业编辑界面。 在Flink OpenSource SQL作业编辑界面，配置如下参数，其他参数默认即可。 所属队列：选择步骤1：创建队列中创建的队列。
作业”。 在创建作业界面，作业类型选择“Flink OpenSource SQL”，名称填写为：FlinkKafkaRds。单击“确定”，跳转到Flink作业编辑界面。 在Flink OpenSource SQL作业编辑界面，配置如下参数，其他参数默认即可。 所属队列：选择步骤1：创建队列中创建的队列。
单击“语义校验”，确保语义校验成功。 单击“启动”，进入“启动Flink作业”页面，确认作业规格和费用后，单击“立即启动”，启动作业。 启动作业后，系统将自动跳转到Flink作业管理页面，新创建的作业将显示在作业列表中，在“状态”列中可以查看作业状态。作业提交成功后，状态将由“提交中”变为“运行中”。
'topic-1;topic-2'。 对 source 表而言，'topic' 和 'topic-pattern' 两个选项只能使用其中一个。 当表被用作 sink 时，该配置表示写入的 topic 名。注意 sink 表不支持 topic 列表。 topic-pattern 否 无 String
Kafka消息的时间戳类型： NoTimestampType：消息中没有定义时间戳。 CreateTime：消息产生的时间。 LogAppendTime：消息被添加到Kafka Broker的时间。 其书写方式请参考示例1。 示例（适用于Kafka集群未开启SASL_SSL场景） 示例1：读取Kafka的元信息列，输出到Print
Kafka消息的时间戳类型： NoTimestampType：消息中没有定义时间戳。 CreateTime：消息产生的时间。 LogAppendTime：消息被添加到Kafka Broker的时间。 其书写方式请参考示例1。 示例（适用于Kafka集群未开启SASL_SSL场景） 示例1：读取Kafka的元信息列，输出到Print
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
