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.
<code>org.apache.kafka.common.errors.UnsupportedVersionException: Cannot create a v0 FindCoordinator request because we require features supported only in 2 or later.
</code>
<code>org.apache.kafka.common.errors.UnsupportedVersionException: Cannot create a v0 FindCoordinator request because we require features supported only in 2 or later.
</code>
org.apache.kafka.common.errors.UnsupportedVersionException: Cannot create a v0 FindCoordinator request because we require features supported only in 2 or later.
Tried updating the kafka-clients version from 1.1.1 to 2.0.0 but still the error persists.
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.0.0</version> </dependency>
New contributor
Sai Ashish is a new contributor to this site. Take care in asking for clarification, commenting, and answering.
Check out our Code of Conduct.