Getting below error
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/clients/admin/AdminClient
while connecting flink to kafka
I am using flink 1.17 and using
flink-sql-connector-kafka-1.17.2.jar
kafka-clients-0.10.2.2.jar
flink-sql-connector-kafka-1.17.2.jar additional jars. Please help if I am missing something.
Tried different versions of Jars but nothing seems to work. Also I am using dataproc cluster for the same.