Hi,
I am following the documentation under:
https://kafka.apache.org/documentation/#connect_user
https://docs.confluent.io/current/connect/userguide.html
For testing I am using standalone mode. And I am using kafka_2.12-2.3.1.

So I have defined:
plugin.path=/path/to/plugin/dir
In file: config/connect-standalone.properties

When I run the connect command using:
connect-standalone.bat config/connect-standalone.properties
/path/to/plugin-connect.properties

I get lot of errors like:
org.reflections.ReflectionsException: could not get type for name xxx
....
Caused by: java.lang.ClassNotFoundException:xxx

However in the logs I do see this entry:
INFO Loading plugin from:
/path/to/plugin/dir/kafka-connect-plugin-xxx-all.jar
(org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader)
INFO Reflections took 3801 ms to scan 1 urls, producing 6893 keys and 48017
values [using 8 cores] (org.reflections.Reflections)

So looks like plugin go loaded properly, but somehow its jar has not got
added to classpath.
If I check the plugin uber jar, it has all the classes the connect failed
to load. So any idea as I need to do something extra to get the jar also
path of classpath.

Thanks
Sachin

Reply via email to