Flink kafka connector and flink version

Question

flink kafka connector doc says we should not upgrade Flink and Kafka Connector version at the same time.

But I can not use old version Kafka Connector with newer Flink.

I try to use flink-connector-kafka-010 1.10.2 with Flink 1.14 and get Exception: java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apache/flink/api/common/state/ListState;

So can I just upgrade Flink and Kafka Connector version at same time and use offset in Kafka broker with same group id?

Answer 1

You should first upgrade to a newer version of your Kafka connector on your existing Flink version, before upgrading to a newer version of Flink.