消息队列MQ
消息队列（Message Queue）简称MQ，是阿里云商用的专业消息中间件，是企业级互联网架构的核心产品。消息列队是基于高可用分布式集群技术，搭建了包括发布订阅、消息轨迹、资源统计、定时（延时）、监控报警等一套完整的消息云服务。
实时计算 Flink可以将消息队列作为流式数据输入，如下所示。
CREATE TABLE stream_test_hotline_agent (id INTEGER,len BIGINT,content varchar) WITH (type='mq',endpoint='XXXXX',accessID='XXXXX',accessKey='xxxxxx',topic='blink_daily_test_topic_1',producerGroup='PID_001',tag='asd',encoding='utf-8',fieldDelimiter=',',retryTimes='5',sleepTimeMs='500');
WITH参数
| 参数 |
注释说明 |
备注 |
| topic |
写入的MetaQ队列名 |
无 |
| endpoint |
地址 |
公共云内网接入（阿里云经典网络/VPC）：华东1、华东2、华北1、华北2、华南1
***的区域endpoint的地址是：onsaddr-internal.aliyun.com:8080
公共云公网接入地址是：http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet
|
| accessID |
填写自己的ID |
无 |
| accessKey |
填写自己的Key |
无 |
| producerGroup |
写入的群组 |
无 |
| tag |
写入的标签 |
可选，默认为空 |
| fieldDelimiter |
字段分割符 |
可选，默认为\u0001 。表示 Crtl+A 和 \001，(暂不支持\001写法）。 |
| encoding |
编码 |
可选，默认为utf-8 |
| retryTimes |
写入重试次数 |
可选，默认为10 |
| sleepTimeMs |
重试间隔时间 |
可选，默认为1000（毫秒） |
