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

请教大家一个Flink CDC 中debezium的问题,假设我一个数据库中上千的表,需要放到一个?

请教大家一个Flink CDC 中debezium的问题,假设我一个数据库中上千的表,需要放到一个topic下面,然后这个topic建16个分区,我怎么能确保一个表的同一条数据,始终在一个分区下,如何配置?

问答 2022-09-15 来自:开发者社区

10几个库,cdc 只能读到第一个库,权限都是最高了,读其他库的时候 报找不到 对应数据库的表为什么

rds mysql 一个实例 有 10几个库,cdc 只能读到第一个库,权限都是最高了,读其他库的时候 报找不到 对应数据库的表12:05Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to discover captured tables for enumerator at com.ververica.cdc.con....

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

产品推荐