Flink kafka连接器和flink版本
Flink kafka连接器和flink版本
提问于 2022-08-31 07:19:00
flink kafka连接器文档说我们不应该同时升级Flink和Kafka连接器版本。
但是我不能用旧版本的卡夫卡连接器与更新的Flink。
我尝试使用Flink -连接器-kafka-010 1.10.2和Flink 1.14，并获得异常：java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apache/flink/api/common/state/ListState;
那么，我是否可以同时升级Flink和Kafka连接器版本，并在具有相同组id的Kafka broker中使用偏移量？
回答 1
Stack Overflow用户
回答已采纳
发布于 2022-08-31 08:23:22
在升级到新版本的Flink之前，您应该首先在现有Flink版本上升级到您的Kafka连接器的更新版本。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/73552192
复制相关文章
相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号