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

Flink CDC里这个是Kafka写入Doris,Doris表一条数据也没有是为啥?

Flink CDC里这个是Kafka写入Doris,Doris表一条数据也没有,也开启了ck。有大佬可以提供下问题思路吗?com.selectdb.flink.sink.writer.JsonDebeziumSchemaSerializer [] - ddl can not do schema change:

问答 2023-12-24 来自:开发者社区

Flink CDC这个cdc到kafka的数据怎么带个T,怎么不用代码处理,不然写不进doris?

Flink CDC这个cdc到kafka的数据怎么带个T,怎么不用代码处理,不然写不进doris?

文章 2023-12-20 来自:开发者社区

Flink CDC可以从Kafka消费数据并写入到Doris中

是的,Flink CDC可以从Kafka消费数据并写入到Doris中。Flink CDC支持从多种数据库(如MySQL、MariaDB、PG、Oracle、MongoDB 、Oceanbase、TiDB、SQLServer等)捕获变更数据,并将这些变更实时同步到下游存储,包括Kafka、Pulsar消息队列,以及...

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

flink cdc 能从kafka消费数据 写到doris吗?

flink cdc 能从kafka消费数据 写到doris吗?

文章 2023-12-04 来自:开发者社区

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,但是也没有输出,大家有遇到过么?

在使用Flink CDC将Kafka中的数据写入Doris时,如果没有任何错误信息但也没有输出结果,可能的原因和解决方法包括: 检查源表的元数据:确保从Kafka读取的数据列与目标Doris表的列相匹配。这包括列的数量、名称和类型。 确认数据是否正确流入Kafka:可以使用如kafka-console-consumer.sh工...

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

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,有遇到过么?

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,但是也没有输出,大家有遇到过么?

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

Flink CDC消费kafka,入库到doris,会把kafka的元数据时间戳存到doris?

Flink CDC消费kafka,入库到doris,会把kafka的元数据时间戳存到doris,doris有个默认时间字段,查看数据,doris的默认时间字段竟然比kafka元数据时间戳还要早个将近一秒,看了服务器没有时间差?

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

产品推荐

消息队列

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

+关注