阿里云文档 2025-07-25

调用UpgradeInstanceVersion接口升配实例版本

升级实例版本。

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

消息队列Kafka版如何不自动升级集群小版本

消息队列Kafka版如何不自动升级集群小版本

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

Flink CDC里cdh 5.9版本的kafka 指定消费组ID消费,为啥消息能消费?

Flink CDC里请教一个大数据组件问题,cdh 5.9版本的kafka 指定消费组ID消费, zk中无法注册consumers 但是消息能消费是为什么?

问答 2024-04-17 来自:开发者社区

不同版本的 flink 如何适配不同版本 kafka,flink-connect-kafka 版本

开发环境: oracle jdk 11 flink 1.19.0 kafka_2.12-2.6.3 我从flink官网复制代码粘贴后,应该如何确定 flink-connect-kafka 的版本。 官网有提供文档吗,针对不同版本的 kafka 。

文章 2024-04-08 来自:开发者社区

Springboot集成高低版本kafka

1、版本选择 springboot整合kafka的时候一定要根据自己springboot版本选择对应版本的kafka,两者版本对应关系可以直接查看官网 https://spring.io/projects/spring-kafka#overview 2、低版本springboot整合kafka ...

Springboot集成高低版本kafka
问答 2024-02-25 来自:开发者社区

Flink1.18可以支持的kafka的最低版本是多少?

Flink1.18可以支持的kafka的最低版本是多少?

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

Flink1.14.4版本消费kafka数据,能外部保存偏移量并维护吗?

Flink1.14.4版本消费kafka数据,能外部保存偏移量并维护吗?

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

Flink1.18.0版本连接外部kafka本地执行测试代码报错

版本:Flink1.18.0代码如下:```public static void main(String[] args) { //1、创建TableEnvironment EnvironmentSettings settings = EnvironmentSettings.newInstance().build(); TableEnvironment tEnv = Tab...

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

Flink CDC中kafka版本是1.1.1,都无法消费kafka了吗?

Flink CDC中kafka版本是1.1.1,原本打算升级flink版本到1.17的 但是flink版本升级后 jar包变成flink-sql-connector-kafka-1.17.0.jar 无论是用KafkaSource类还是FlinkConsumer类 都无法消费kafka了?我之前是flink1.14版本 引用的jar是flink-connector-kafka_2.12,用fli....

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

Flink CDC1.16版本,从oracle同步到kafka,请问你们怎么解决的?

Flink CDC1.16版本,从oracle同步到kafka,kafka的配置信息如下:报这个错误:Caused by: org.apache.kafka.common.errors.InvalidProducerEpochException: Producer attempted to produce with an old epoch.请问你们怎么解决的?小数据量表就没有问题,大数据量表1....

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

产品推荐

消息队列

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

+关注