Java Flink NoClassDefFoundError org/apache/flink/shaded/guava30/com/google/common/io/Closer
I have a Java 21 application that uses Apache Flink (version 1.20.0) dependencies for filtering kafka stream.
org.apache.kafka.common.errors.UnsupportedVersionException
Tried to upgrade Flink version from 1.14.2 to 1.17.1 for an already running application. The application has source and sink as Kafka (different topics same cluster). After upgrading the version the following error was thrown.