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

flink实时同步这边对源库和目标的版本要求是啥?

flink实时同步这边对源库和目标的版本要求是啥?

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

Flink CDC里我cdc2.3升级3.0,flink最低版本要求是多少?

Flink CDC里我cdc2.3升级3.0,flink最低版本要求是多少?我现在就是2.3+1.16>3.0+1.8,我从1.6升级到1.8遇到了很严重的版本兼容问题。。

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

Flink CDC对关闭reader是否有版本要求?

Flink CDC中flink-connector-mysql-cdc 对关闭reader是否有版本要求?我的flink是1.17.1版,flink-connector-mysql-cdc是2.3.0版?

问答 2021-12-07 来自:开发者社区

flink new source api, kafka部分对kafka-client的版本要求。

如题,当前新的kafaksouce貌似对kafka-client版本做了依赖,比如代码KafkaPartitionSplitReader.acquireAndSetStoppingOffsets方法中用到的 consumer.committed(partitionsStoppingAtCommitted) .forEach( (tp, offsetAndMetadata) -> { Prec...

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等