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

在Flink CDC中,导致输出到kafka的数据错误是哪里配置问题吗?

在Flink CDC中,pipeline mysql到kafkamysql类型decimal(16,2)但flink日志里面 schema信息是decimal(19,0)导致输出到kafka的数据错误是哪里配置问题吗?

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

在Flink CDC中mysql_to_kafka, 配置如下,如何操作?

在Flink CDC中mysql_to_kafka, 配置文件中写了sink.add-tableId-to-header-enabled: true,查看topic数据,发现还是没生效。flink-cdc-3.1.0,如何操作?

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

Flink CDC里通过datastream从mysql写到kafka中文乱码要配置什么的?

Flink CDC里通过datastream从mysql写到kafka中文乱码要配置什么的?

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

flink cdc 不需要依赖kafka啊, 即使配置了ha, 不就能恢复了吗?

flink cdc 不需要依赖kafka啊, 即使配置了ha, jobmanager读取checkpoint不就能恢复了吗?

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

flink cdc 怎么批量拉取kafka里面的数据,我配置了参数,每次还是一条?

flink cdc 怎么批量拉取kafka里面的数据,我配置了参数,每次还是一条?

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

在mysql cdc出来,通过data stream写入kafka,但没有操作的flag,在哪配置?

我有个疑问,在从mysql cdc出来,通过data stream写入kafka,目前kafka消息里面有数据,但是没有操作的flag(insert、update、delete), 这个是在哪里配置呢?

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

各位老板 如何保证cdc全量读取完之后 再读取kafka的数据呀? 因为cdc读的是配置数据

各位老板 如何保证cdc全量读取完之后 再读取kafka的数据呀? 因为cdc读的是配置数据 如果全量阶段没有读取完 害怕有部分数据会关联不上啊?

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

产品推荐

消息队列

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

+关注