问答 2024-07-15 来自:开发者社区

在Flink CDC中flink支持消费rocketmq的数据不?

在Flink CDC中flink支持消费rocketmq的数据不?

问答 2024-07-11 来自:开发者社区

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的之外,还有其他参数吗?

flink链接rocketMQ5.*的时候,需要配置的属性字段除了文档里给的这四个字的之外,还有其他的必要参数嘛?:CREATE TEMPORARY TABLE source_table ( mess varbinary) WITH ( 'connector' = 'mq5', 'endpoint' = '', 'topic' = 'mq-test', 'consumerGroup' ...

RocketMQ 5.0学习资料

7 课时 |
91 人已学 |
免费

Apache RocketMQ:如何从互联网时代演进到云

1 课时 |
267 人已学 |
免费

带您快速了解阿里云消息队列RocketMQ 5.0版

5 课时 |
1292 人已学 |
免费
开发者课程背景图
文章 2024-06-17 来自:开发者社区

实时计算 Flink版操作报错合集之连接RabbitMQ时遇到Could not find any factory for identifier 'rabbitmq' that implements 'org.apache.flink.table.factories.DynamicTableFactory'错误,该怎么办

问题一:Flink CDC版本1.15.0,mongocdc版本2.2.1,flinksql同步报错,为啥? Flink CDC版本1.15.0,mongocdc版本2.2.1,flinksql同步报错,为啥? 参考回答: 根据您提供的信息,报错信息显示"BSON field '$changeStream.allChangesForCluster' is an ...

文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之是否要在中间加个RocketMq做为缓冲层

问题一:我的 kafka数据到目标表的作业 ,要进行 无状态 启动时。Flink是不是就没办法 全量同步 ...

实时计算 Flink版产品使用问题之是否要在中间加个RocketMq做为缓冲层
文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之sink多个并行度写入rabbit mq会导致顺序性问题吗

问题一:Flink中keyby以后是按照每个key值分别开窗吧?不同key值的窗口是互不影响的对吗? Flink中keyby以后是按照每个key值分别开窗吧?不同key值的窗口是互不影响的对吗? 参考答案: 按照每个key值分别开窗 是Session窗口 , 关于本问题的更多回答可点击进行查看: https://de...

实时计算 Flink版产品使用问题之sink多个并行度写入rabbit mq会导致顺序性问题吗
问答 2024-06-14 来自:开发者社区

Flink连接MQ报错com.alibaba.rocketmq.remoting.except...

Flink连接MQ报错com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to failed

问答 2024-06-14 来自:开发者社区

Flink RocketMQ的instanceID参数什么情况下填写

Flink RocketMQ的instanceID参数什么情况下填写

问答 2024-05-30 来自:开发者社区

Flink中RocketMQ能否设定消息的读取方式如kafka的scan.startup.mo...

Flink中RocketMQ能否设定消息的读取方式如kafka的scan.startup.mode= latest-offset

问答 2024-05-24 来自:开发者社区

Flink1.15-vvr-6.0.2对应的ververica-connector-mq这个J...

Flink1.15-vvr-6.0.2对应的ververica-connector-mq这个JAR包能否提供

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之有没有rocketMq的connector

问题一:flink 有没有rocketMq的connector ? flink 有没有rocketMq的connector ? 参考回答: 确实没看到,不过有人写好的https://github.com/deemogsw/rocketMQ-flink-connector验证了checkpoint没问题 关于本问题的更多回答可点击原文查...

实时计算 Flink版产品使用合集之有没有rocketMq的connector

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。