rocketmq SQL-阿里云

问答 2024-06-05 来自：开发者社区

RocketMQ arms 链路分析查看不了sql 的具体时间参数什么原因呢？

问答 2024-04-15 来自：开发者社区

RocketMQ用SQL过滤属性，能实现灰度吗？

文章 2024-01-02 来自：开发者社区

RocketMQ-初体验RocketMQ(10)-过滤消息_SQL92表达式筛选消息

过滤消息概述大部分情况下，我们都可以通过TAG来选择我们想要获取的消息，如下DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_EXAMPLE"); consumer.subscribe("TOPIC", "TAGA || TAGB || TAGC");消费者将接收包含TAGA或TAGB或TAGC的消息。但是限制是一个....

问答 2023-10-05 来自：开发者社区

MSE微服务引擎rocketmq升级到了铂金版，报错不指定SQL92 exception is ?

MSE微服务引擎rocketmq升级到了铂金版，报错不指定SQL92exception is com.aliyun.openservices.ons.api.exception.ONSClientException: CODE: 1 DESC: The broker does not support consumer to filter message by SQL92？

问答 2023-09-25 来自：开发者社区

麻烦哪位同事给看下： rocketmq升级到了铂金版，报错不指定SQL92 exception i

麻烦哪位同事给看下：rocketmq升级到了铂金版，报错不指定SQL92exception is com.aliyun.openservices.ons.api.exception.ONSClientException: CODE: 1 DESC: The broker does not support consumer to filter message by SQL92

问答 2023-03-07 来自：开发者社区

rocketmq-flink ，支持flink sql 方式写rocketmq时这个连接器怎么用呢？

rocketmq-flink ，支持flink sql 方式写rocketmq时这个连接器怎么用呢？这个包放进来后，yarn上flink容器创建各种找不到类是为什么？

问答 2023-02-27 来自：开发者社区

实时计算 Flink版大家有写过rocketmq的sql connector 吗?

文章 2023-02-25 来自：开发者社区

RocketMQ的TAG过滤和SQL过滤机制

TAG如果使用TAG去获取自己感兴趣的消息，那么对于一条学生表变更binlog，最少要插入三条消息，比如TAG=学生表，比如TAG=UPDATE修改操作，比如TAG=学生状态为1，等等。想到的就三种。。。所以上面这种方式缺陷还是挺明显的。SQL过滤如果使用SQL过滤的方式，我们可以对某些属性进行过滤，自己拼接SQL，灵活性就上来了。但是我好奇的一点是SQL怎么加到TAG里呢？并且TAG只能支持一....

问答 2023-02-22 来自：开发者社区

大家有写过rocketmq的sql connector 吗？