flink云消息队列 MQ 的相关内容

问答 2024-08-18 来自：开发者社区

flink cdc 监听发送数据到rocketmq ，但是运行一段时间后发送失败怎么办?

flink cdc 监听mysql binlog 发送数据到rocketmq ，但是运行一段时间后发送失败内存oom，有没有什么好的办法呢?

问答 2024-08-14 来自：开发者社区

Flink的vvp 支持 rabbitmq 吗？有内置的连接器吗？

问答 2024-08-14 来自：开发者社区

在Flink用vvp 将数据同步到我们自建的rabbitmq l里是不是加 vvp的白名单才行？

问答 2024-08-14 来自：开发者社区

Flink中通过MQ的连接器消费数据时有确认机制吗？

Flink中通过MQ的连接器消费数据时有确认机制吗？比如我消费成功了，mq那边能确认消费成功。在官方的配置文档中没有看到有类似回调的参数

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

在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' ...

文章 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是不是就没办法全量同步 ...

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

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

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