Kafka Connect Plugin Path

Kafka Connect
1

Hi,

In the worker_config , I am specifying the plugin.path as "/u/goyaltu/Documents/RAFT/raft-core/java/lean-jar" , so there are 4 jars inside it, two are the lean jars of two connectors - JDBC and PyConnect, and other two are dependencies where one of the jar is dependency of both of the connectors.

In the logs I am able to see all 4 jars from plugin are loaded and registered.
When I am submitting the connector, it is giving java.lang.NoClassDefFoundError which is there in the dependency jar already.

    "workers": {
      "count": 1,
      "worker_config": {
        "plugin.path": [
	    "/u/goyaltu/Documents/RAFT/raft-core/java/lean-jar"
        ]
      }
    }

lean_jar

Can someone help with the problem?

why is the class not able to found when connector is submitted although it is there in plugin.path already

2

After deploying the connector plugin, did you restart the connect service? This step is mandatory for the connect service to pickup and add the latest connector-specific JARs to the classpath and make them available to the Connect service.

3

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.