Flink配置消息队列Kafka源表时,Kafka集群需要SASL(Simple Authentic
Flink配置消息队列Kafka源表时,Kafka集群需要SASL(Simple Authentication and Security Layer)认证,此时DDL with参数应该怎么配置
创建消息队列(MQ)源表
本页目录 什么是消息队列MQ 示例 CSV类格式 WITH参数 类型映射 什么是消息队列MQ 消息队列(Message Queue),简称MQ。是阿里云商用的专业消息中间件,是企业级互联网架构的核心产品。基于高可用分布式集群技术,搭建了包括发布订阅、消息轨迹、资源统计、定时(延时)、监控报警等一套完...
创建消息队列(Kafka)源表
本页目录 WITH参数 kafka版本对应关系 Kafka消息解析 自建kafka WITH参数 Kafka源表的实现来源于自社区的kafka版本实现。 注意:本文档只适合独享模式下使用。 Kafka需要定义的DDL如下。 create table kafka_stream( messageKey ...
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。