Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?
Flink CDC有同时包含kafka以及cdc的pom文件啊 我这边一直在报依赖问题?
Flink CDC这种只是争对kafka的,如果是针对flink的多并行度呢,是不是也是一致的呢?
Flink CDC这种只是争对kafka的,如果是针对flink的多并行度呢,是不是也是一致的呢!比方说我一个source并行度为4,那么是不是针对单条记录的增删改就会在一个并行度里呢,如果是这样的话,那么如果我加上schemaChange后,是不是其他几个并行线程的数据就会先于schemaChan...
Flink CDC为啥我任务消费kafka数据到这就停止了?
Flink CDC为啥我任务消费kafka数据到这就停止了?kafka数据有积压
Flink CDC是不是部署kafka的服务器一定要能直接访问上游的数据库?
Flink CDC使用kafka采集上游数据,是不是部署kafka的服务器一定要能直接访问上游的数据库?
Flink CDC中sink如果异常了 ,如何处理? 比如kafka宕机。数据会丢吗?
Flink CDC中sink如果异常了 ,如何处理? 比如kafka宕机。数据会丢吗?
Flink CDC两台服务器传输数据,在sink端部署kafka接收数据,是否可行?
问题1:Flink CDC两台服务器传输数据,相互间无法访问对方的数据库,但服务器ip可以ping通,无法使用flink sql模式同步如果我在source端使用flink cdc捕获数据,在sink端部署kafka接收数据,是否可行?类似于这种模式?问题2:采用这种模式?source端使用debe...
Flink CDC中debezium必须要搭配kafka使用吗?
Flink CDC中debezium必须要搭配kafka使用吗?
Flink 处理 Kafka的数据,需要 join 一个基础表来计算,会实时的体现在 计算结果里吗?
请教一个问题:Flink 处理 Kafka的数据,需要 join 一个基础表来计算,如果这个基础表的数据有更新,会实时的体现在 计算结果里吗?还是说 基础表更新后,需要重新运行这个 flink 任务才可以起作用?
Flink CDC这个权限问题的么,场景是从Kafka -> hive ,通过FlinkSQL实现?
Flink CDC这个权限问题的么,场景是从Kafka -> hive ,通过FlinkSQL实现,在dolphinscheduler调度。Permission denied: user=dolphinscheduler, access=READ, inode="/warehouse/tabl...
更新时间 2023-09-21 03:50:41
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
社区圈子