Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ERROR Plugin class loader for connector #45

Closed
amlen opened this issue Apr 12, 2020 · 18 comments
Closed

ERROR Plugin class loader for connector #45

amlen opened this issue Apr 12, 2020 · 18 comments

Comments

@amlen
Copy link

amlen commented Apr 12, 2020

Hi ,

I have this error can u help me please

ERROR Plugin class loader for connector: 'com.ecer.kafka.connect.oracle.OracleSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@2b546384 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader)

@erdemcer
Copy link
Owner

Hi,
To where did you copy jar file ? Does your CLASSPATH see this location ?

@amlen
Copy link
Author

amlen commented Apr 12, 2020

i copy Copy kafka-connect-oracle-1.0.jar and lib/ojdbc7.jar to KAFKA_HOME/lib folder.

Does your CLASSPATH see this location ? No

@erdemcer
Copy link
Owner

Before execution i set CLASSPATH as
export CLASSPATH=$KAFKA_HOME/share/java/kafka/:$KAFKA_HOME/share/java/kafka-connect-jdbc/

and my jar files are in $KAFKA_HOME/share/java/kafka-connect-jdbc
You are free to copy jar files to anywhere , but CLASSPATH must see this location .

@amlen
Copy link
Author

amlen commented Apr 12, 2020

Now i hve this error
ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone)
java.nio.file.NoSuchFileException: ....\config\OracleSourceConnector.propertieso

@erdemcer
Copy link
Owner

Is the OracleSourceConnector.propertieso file in the proper location you set while starting connector? Could you please check it ?

@amlen
Copy link
Author

amlen commented Apr 12, 2020

Is the OracleSourceConnector.propertieso file in the proper location you set while starting connector? Could you please check it ?

sorry its a typing error, but i still have this error : ERROR Plugin class loader for connector: 'com.ecer.kafka.connect.oracle.OracleSourceConnector' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@2b546384 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader)

@erdemcer
Copy link
Owner

Hi,
Issue can be related with following issue , Could you please check it out with your configuration ?
confluentinc/kafka-connect-jdbc#766
Thanks

@charliecat22
Copy link

I have the same issue work with kafka_2.11-2.4.0 .
Then I change to kafka_2.11-2.1.1 , this error not report.

@erdemcer
Copy link
Owner

Hi,
Delete all kafka-connect-oracle-1.0.jar and ojdbc7.jar jar files from directories where you copied . Then only copy these jar files to $KAFKA_HOME/share/java/kafka directory. This location is set as classpath while starting connector . Do not set any classpath variable . Then try to start . If error continues , could you please send all output ?
Thanks

@amlen
Copy link
Author

amlen commented Apr 13, 2020

Hi,
I deleted all kafka-connect-oracle-1.0.jar and ojdbc7.jar jar files from directories where i copied . Then i only copy these jar files to $KAFKA_HOME/share/java/kafka directory.

I set this location($KAFKA_HOME/share/java/kafka directory) as classpath

but i had this error :

ERROR Failed to create job for ../../config/OracleSourceConnector.properties (org.apache.kafka.connect.cli.ConnectStandalone)

then i added this line plugin.path=C:/kafka_2.11-2.4.1/share/java/kafka, into connect-standalone.properties file

but i have this error
ERROR WorkerConnector{id=oracle-logminer-connector} Error while shutting down connector (org.apache.kafka.connect.runtime.WorkerConnector)
java.lang.NoClassDefFoundError: net/sf/jsqlparser/JSQLParserException
at com.ecer.kafka.connect.oracle.OracleSourceConnector.stop(OracleSourceConnector.java:56)
at org.apache.kafka.connect.runtime.WorkerConnector.shutdown(WorkerConnector.java:172)
at org.apache.kafka.connect.runtime.Worker.stopConnector(Worker.java:369)
at org.apache.kafka.connect.runtime.standalone.StandaloneHerder.stop(StandaloneHerder.java:114)
at org.apache.kafka.connect.runtime.Connect.stop(Connect.java:69)
at org.apache.kafka.connect.runtime.Connect$ShutdownHook.run(Connect.java:100)
Caused by: java.lang.ClassNotFoundException: net.sf.jsqlparser.JSQLParserException
at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:435)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:589)
at org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:104)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:522)
Thanks

@charliecat22
Copy link

Hi amlen,
I copy kafka-connect-oracle-1.0.jar to $KAFKA_HOME/share/java/kafka, copy ojdbc7.jar to $KAFKA_HOME/libs and edited connect-standalone.properties : plugin.path=$KAFKA_HOME/share/java/kafka.
No error report

@amlen
Copy link
Author

amlen commented Apr 13, 2020

Hi amlen,
I copy kafka-connect-oracle-1.0.jar to $KAFKA_HOME/share/java/kafka, copy ojdbc7.jar to $KAFKA_HOME/libs and edited connect-standalone.properties : plugin.path=$KAFKA_HOME/share/java/kafka.
No error report

Thanks for your response , I did all what you mentioned , but i still have this error : ERROR Failed to start task oracle-logminer-connector-0

which path did you set in CLASSPATH ? $KAFKA_HOME/share/java/kafka or $KAFKA_HOME/libs ?

@charliecat22
Copy link

Hi amlen,
I copy kafka-connect-oracle-1.0.jar to $KAFKA_HOME/share/java/kafka, copy ojdbc7.jar to $KAFKA_HOME/libs and edited connect-standalone.properties : plugin.path=$KAFKA_HOME/share/java/kafka.
No error report

Thanks for your response , I did all what you mentioned , but i still have this error : ERROR Failed to start task oracle-logminer-connector-0

which path did you set in CLASSPATH ? $KAFKA_HOME/share/java/kafka or $KAFKA_HOME/libs ?

I set $KAFKA_HOME/share/java/kafka in CLASSPATH

@amlen
Copy link
Author

amlen commented Apr 13, 2020

thanks No error report but i have warning and no message in the topic

The (sub)resource method createConnector in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectors in org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource contains empty path annotation.
WARNING: The (sub)resource method listConnectorPlugins in org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource contains empty path annotation.
WARNING: The (sub)resource method serverInfo in org.apache.kafka.connect.runtime.rest.resources.RootResource contains empty path annotation.

@erdemcer
Copy link
Owner

This issue is same as #43 . Is your kafka version 2.11-2.4.0 ? and if it is possible i would like to see your issue from remote ?

@amlen
Copy link
Author

amlen commented Apr 14, 2020

This issue is same as #43 . Is your kafka version 2.11-2.4.0 ? No my kafkfka version is kafka_2.11-2.4.1

and if it is possible i would like to see your issue from remote ? yes

@erdemcer
Copy link
Owner

Hi,
Sometimes in connector config table.whitelist and table.blacklist values are written in lower case . Could you please check them ? They must be in uppercase.
Thanks

@amlen
Copy link
Author

amlen commented Apr 17, 2020

i set config table.whitelist and table.blacklist values in uppercase
but i still not get any data

my config :
name=oracle-logminer-connector
connector.class=com.ecer.kafka.connect.oracle.OracleSourceConnector
db.name.alias=
tasks.max=1
topic=test
db.name=ORCL1
db.hostname=localhost
db.port=1521
db.user=userTest
db.user.password=userTest
db.fetch.size=1
table.whitelist=ORCL1.TEST
table.blacklist=ORCL1.TESTBLACK
parse.dml.data=true
reset.offset=false
multitenant=false
start.scn=

@amlen amlen closed this as completed Apr 30, 2020
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants