Kafka connect not finding com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler

Just installed the kafka-couchbase connectors plugin but I can’t get the connector to load as the connect build looks to be missing something and cannot find at least this class
com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler

See the error below.

[2022-06-24 23:36:40,703] ERROR Failed to create job for config/connect-couchbase-incentiveData-source.properties (org.apache.kafka.connect.cli.ConnectStandalone:107)
[2022-06-24 23:36:40,703] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:117)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 1 error(s):
Invalid value com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler for configuration couchbase.source.handler: Class com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler could not be found.
You can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`
        at org.apache.kafka.connect.util.ConvertingFutureCallback.result(ConvertingFutureCallback.java:115)
        at org.apache.kafka.connect.util.ConvertingFutureCallback.get(ConvertingFutureCallback.java:99)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:114)
Caused by: org.apache.kafka.connect.runtime.rest.errors.BadRequestException: Connector configuration is invalid and contains the following 1 error(s):
Invalid value com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler for configuration couchbase.source.handler: Class com.couchbase.connect.kafka.handler.source.RawJsonMetadataSourceHandler could not be found.
You can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate`
        at org.apache.kafka.connect.runtime.AbstractHerder.maybeAddConfigErrors(AbstractHerder.java:638)
        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.putConnectorConfig(StandaloneHerder.java:203)
        at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.lambda$null$0(StandaloneHerder.java:189)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:829)
[2022-06-24 23:36:40,706] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect:67)

I did the unzip and moved all the lib files to my Kafka plugins folder, and the etc files to my config folder. I didn’t see anything about other folders or things I need to install. Did I miss a step?

We’re using kafak version kafka_2.13-2.8.0 and the CB connector version 4.1.7

Hi @elbilo ,

Looks like the class name in the connector config might be incorrect. Did you mean RawJsonWithMetadataSourceHandler ? Full name:

com.couchbase.connect.kafka.handler.source.RawJsonWithMetadataSourceHandler

Thanks,
David

thank you for responding.