阿里云文档 2024-06-28

修改消息配置信息

您可以按照业务需求调整消息保留时长、最大消息大小、消费位点保留时间和SSL证书算法位数。

问答 2023-07-25 来自:开发者社区

Flink的mysql发生ddl变更后,这个ddl会修改kafka的数据吗?

Flink的mysql发生ddl变更后,这个ddl会修改kafka的数据吗?然后这个ddl还会存在kafka中吗?下游的sr或者paimon会收到ddl变更吗?

问答 2023-06-18 来自:开发者社区

Flink CDC中这个监听的数据变更是默认丢到kafka 里面吗? 我该已什么方式去获取到这个表

Flink CDC中这个监听的数据变更是默认丢到kafka 里面吗? 我该已什么方式去获取到这个表更消息的呀 大佬们 我用的 flink 2.4 flinkcdc 1.6.2

问答 2023-05-04 来自:开发者社区

canal集成kafka后,每变更一次数据,会发送多次信息给kafka

我想变成每次修改只发送一次信息,请问我需要调整什么配置 原提问者GitHub用户haoshichong

问答 2023-02-06 来自:开发者社区

企业版flinkcdc,能从hologress捕获变更数据到kafka 或datahub么?

企业版flinkcdc,能从hologress捕获变更数据到kafka 或datahub么?

问答 2022-08-22 来自:开发者社区

flink cdc 消费mongodb变更发到kafka用哪种格式合适?

flink cdc 消费mongodb变更发到kafka用哪种格式合适?

问答 2022-07-03 来自:开发者社区

还有个问题,假如说第二步,接收kafka变更那,如果kafka没有任何变更数据,那第二步就不会广播,

还有个问题,假如说第二步,接收kafka变更那,如果kafka没有任何变更数据,那第二步就不会广播,那第一步的基础数据也就广播不出去了,这情况咋整啊?

问答 2022-07-03 来自:开发者社区

大神们,我想发两个广播流 1 从mysql加载基础数据,广播出去 2 从kafka加载基础数据的变更

大神们,我想发两个广播流 1 从mysql加载基础数据,广播出去 2 从kafka加载基础数据的变更,广播出去 3 业务数据连接1,2这两个广播流 这种想法能实现吗?

问答 2020-05-23 来自:开发者社区

canal集成kafka之后,每次mysql变更数据,会传递多条数据至kafka

canal集成kafka之后,每次mysql变更数据,会传递多条数据至kafka,但这几条数据除一些不重要的字段如起止时间之外都是一致的,我想知道为何会发送多条数据,如果可以的话,能不能只发一条 遇到了同样的问题,在CSDN看到了,希望阿里云团队能够给出正确、标准的答案~请查看

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问