kafka-connect-slack-sink icon indicating copy to clipboard operation
kafka-connect-slack-sink copied to clipboard

Cannot load plugin crashes kafka connect as unable to find dependancies.

Open bob9 opened this issue 6 years ago • 0 comments

After adding plugin seems to fail to find dependancies.. Other plugins working on the kafka connect server running confluent 5.0.0 installed via confluent helm package..

Thats the Dockerfile i am using to create the kafka connect docker image.

Any help would be appreciated. I used the 0.1.2 version in releases had so luck so compiled it fresh however still had not luck with local compiled version.

FROM confluentinc/cp-kafka-connect:5.0.0

MAINTAINER Debezium Community

ENV KAFKA_CONNECT_PLUGINS_DIR="/usr/share/java"

ADD plugins/kcbq-connector-1.1.0-confluent-dist $KAFKA_CONNECT_PLUGINS_DIR/kcbq-connector-1.0.0-confluent-dist
# https://repo1.maven.org/maven2/io/debezium/debezium-connector-mysql/0.9.0.Alpha2/
# ADD plugins/debezium-connector-mysql $KAFKA_CONNECT_PLUGINS_DIR/debezium-connector-mysql

# https://dev.mysql.com/downloads/connector/j/  Platform independant
# ADD plugins/mysql-connector-java-8.0.13 $KAFKA_CONNECT_PLUGINS_DIR/mysql-connector-java-8.0.13

# ADD plugins/mysql-jdbc/mysql-connector-java-8.0.12.jar $KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ADD plugins/debezium-connector-mysql $KAFKA_CONNECT_PLUGINS_DIR/debezium-connector-mysql

COPY plugins/debezium-connector-mysql/mysql-connector-java-5.1.40.jar $KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc


ADD plugins/kafka-connect-slack-sink $KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-slack-sink

These are some of the error messages from the kafka connect logs...

cva.lang.ExceptionInInitializerError at clojure.lang.Namespace.(Namespace.java:34) at clojure.lang.Namespace.findOrCreate(Namespace.java:176) at clojure.lang.Var.internPrivate(Var.java:151) at kafka.connect.slack.sink.SinkConnector.(Unknown Source) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at java.lang.Class.newInstance(Class.java:442) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor(DelegatingClassLoader.java:351) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.getPluginDesc(DelegatingClassLoader.java:328) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:309) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:240) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:232) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:201) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:178) at org.apache.kafka.connect.runtime.isolation.Plugins.(Plugins.java:61) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74) Caused by: java.io.FileNotFoundException: Could not locate clojure/core__init.class or clojure/core.clj on classpath. at clojure.lang.RT.load(RT.java:456) at clojure.lang.RT.load(RT.java:419) at clojure.lang.RT.doInit(RT.java:461) at clojure.lang.RT.(RT.java:331) ... 18 more

AEST org.reflections.ReflectionsException: could not get type for name clojure.lang.Sorted at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390) at org.reflections.Reflections.expandSuperTypes(Reflections.java:381) at org.reflections.Reflections.(Reflections.java:126) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.(DelegatingClassLoader.java:406) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:306) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:240) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:232) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:201) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:178) at org.apache.kafka.connect.runtime.isolation.Plugins.(Plugins.java:61) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74) Caused by: java.lang.ClassNotFoundException: clojure.lang.Sorted at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

bob9 avatar Nov 21 '18 03:11 bob9