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

在Flink CDC中这种模式Kafka到mysql可以kakfa到doris不行,也不报错为什么?

在Flink CDC中这种模式Kafka到mysql可以,kakfa到doris不行,也不报错,数据进不了doris,为什么?请参考图片:

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

在Flink CDC中MySQL 整库同步 Kafka,不支持动态加表功能吗?

在Flink CDC中MySQL 整库同步 Kafka,不支持动态加表功能吗?

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

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

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

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

在Flink CDC中明明有创建如下,但是使用同步消费kafka中数据的时候,会显示报错?

在Flink CDC中明明有创建 Topic :tidb_tmp_sync_cdc 但是使用kafka-sync-table同步消费kafka中数据的时候,显示Could not get metadata from server?请参考图片:

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

在Flink CDC中CDC pipeline到kafka,报这个错,是不支持吗?

在Flink CDC中CDC pipeline到kafka,源表字段是bigint,报这个错,是不支持吗?请参考图片:

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

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

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

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

Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办?

Flink CDC3.1.1 Pipeline Connector Options sink.add-tableId-to-header-enabled 配置true以后下游kafka的canal-json内容里没有包括'namespace','schemaName','tableName' 相关信息,有哪位大佬遇到过吗?

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

对于Flink CDC,flink 1.12以上的版本还支持0.10的kafka吗?

对于Flink CDC,flink 1.12以上的版本还支持0.10的kafka吗?

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

CDC是不是,我要先把数据提取到kafka,然后再去分析处理?不是每个脚本都去cdc一次?

CDC是不是,我要先把数据提取到kafka,然后再去分析处理?不是每个脚本都去cdc一次,这样io高?

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

在Flink CDC中消费kafka时如何区分不同record对应是哪个表?

在Flink CDC中Pipeline 从Mysql到Kafka,route映射后,将A库写入topicA,B库写入topicB后,消费kafka时如何区分不同record对应是哪个表?

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

产品推荐

消息队列

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

+关注