问答 2025-01-08 来自:开发者社区

flink cdc实时同步oracle数据库到kafka报错

flink cdc实时同步oracle数据库到kafka,我自己新建的测试表可以正常同步存量和增量数据,用另一张千万级别数据的表直接启动报错Caused by: java.io.IOException: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing.....

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

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?只同步一张表就没有问题 org.apache.flink.table.api.ValidationException: SQL validation failed. From line 195, column 6 to line 195, column 19: Unknown target column 'value__...

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

在Flink CDC中,用pipeline 连接器 同步mysql数据到kafka报错了,缺少什么?

在Flink CDC中,用 pipeline 连接器 同步mysql数据到kafka报错了,是缺少什么依赖了吗?

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

Flink的mysql数据同步到kafka 但是报错了,如何解决?

Flink的mysql数据同步到kafka 但是报错了,如何解决? 文档里是支持debezium-json这个格式的 'upsert-kafka' connector doesn't support 'debezium-json' as key format, because 'debezium-json' is not in insert-only modeCREATE TEMPORARY...

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

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

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

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

在Flink CDC中flink版本1.15,写入kafka报错,如何解决?

在Flink CDC中flink版本1.15,写入kafka报错,如何解决?请参考图片:

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

Flink读取kafka报错No authorized to cmmit to topics

Flink读取kafka报错No authorized to cmmit to topics

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

Flink消费kafka报错Timeout of 60000ms expired before...

Flink消费kafka报错Timeout of 60000ms expired before the position for xxx could be determined

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

Flink连接消息队列Kafka版报错UnsupportedVersionException

Flink连接消息队列Kafka版报错UnsupportedVersionException

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

Flink CDC里遇到过SInk到Kafka的这个报错么?

Flink CDC里遇到过SInk到Kafka的这个报错么:Caused by: org.apache.kafka.common.errors.TimeoutException: Topic XXX not present in metadata after 60000 ms.

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注