Connectors failing with NoClassDefFoundError on CDP clusters

[pugcwc]

Hi team,

I am new to GCP and KafkaConnect, I have deployed the pubsub sink connector jar on CDP clusters and while creating a connector, the connectors are getting failed with issue:

java.lang.NoClassDefFoundError: com/google/common/base/Preconditions\n\tat com.google.api.client.util.Preconditions.checkNotNull(Preconditions.java:125)\n\tat com.google.auth.oauth2.GoogleCredentials.fromStream(GoogleCredentials.java:150)\n\tat com.google.auth.oauth2.GoogleCredentials.fromStream(GoogleCredentials.java:133)\n\tat com.google.pubsub.kafka.common.ConnectorCredentialsProvider.loadJson(ConnectorCredentialsProvider.java:40)\n\tat com.google.pubsub.kafka.sink.CloudPubSubSinkTask.start(CloudPubSubSinkTask.java:166)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:305)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:193)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n

Can you please advice