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

flink cdc datastream方式同步mysql数据到kafka,多分区怎么保证有序性?

flink cdc datastream方式同步mysql数据到kafka,多分区怎么保证有序性?

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

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 分区吗?

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 topic 分区 key吗?

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

在Flink CDC中写入kafka,这个默认是根据什么分区的,表的主键吗?

在Flink CDC中写入kafka,这个默认是根据什么分区的,表的主键吗?请参考图片:

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

Flink CDC中kafka设置的5分区 我们cdc的正常速度大概多少呀?

Flink CDC中kafka设置的5分区 现在kafka设置的是10分区 两种速度都区别不大 算子连拆开的话是不是还有额外的重分区开销,网络带宽是100m的 电脑内存20核64g 想着模拟下性能 我们cdc的正常速度大概多少呀?

问答 2023-10-31 来自:开发者社区

Flink CDC这种报错是需要把kafka的分区增加还是怎么样?

Flink CDC这种报错是需要把kafka的分区增加还是怎么样。(我的问题,flink消费kafka的数据,然后发现flink的webui界面只数据量远远小于实际的)?2023-10-25 16:50:10 ERROR (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:handle) - [Consume...

问答 2023-10-03 来自:开发者社区

Flink CDC 捕获的数据写到kafka里 topic 可以多分区吗 ?

Flink CDC 捕获的数据写到kafka里 topic 可以多分区吗 ?多分区无法保证数据有序的情况下 还能用吗?

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

Flink CDC我自定义了一个flink SQL的Kafka分区器,有遇到这个问题的吗?

Flink CDC我自定义了一个flink SQL的Kafka分区器,在写入的时候会报类型转换异常,有遇到这个问题的吗?

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

哪位大佬有Flink CDC写入Kafka根据指定key分区的代码?借我模仿一下?

哪位大佬有Flink CDC写入Kafka根据指定key分区的代码?借我模仿一下?

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

Flink CDC数据到kafka,同一个主键的所有数据都会放到一个分区吗?

Flink CDC数据到kafka,同一个主键的所有数据都会放到一个分区吗?

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

大佬咨询下,sqlseever cdc 到kafka 多分区,怎么保障消费到下游数据准确性,也就是数

大佬咨询下,sqlseever cdc 到kafka 多分区,怎么保障消费到下游数据准确性,也就是数据正确性?(多分区,同个主键有可能分配到多个kafka分区中),但单个分区性能又上不去,有办法吗?

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

产品推荐

消息队列

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

+关注