Can't connect MySQL to Kafka server

811 views

Skip to first unread message

WATHANYU PHROMMA

unread,

Aug 13, 2018, 1:02:43 PM8/13/18

to debezium

Hi, I need someone's help.

I follow a tutorial Streaming Data from MySQL into Kafka with Kafka Connect and DebeziumI but I have the trouble connecting MySql to Kafka server using Debezium MySQL Connector.

Here is my setup and other information.

OS : Windows 10.

Kafka Connect : Confluent 5.0.

MySQL Connector : 0.8.1 Final.

I keep files here.

I add the plugins path.

When I tried connecting to Kafka Connect, It returned me an error.

"Failed to find any class that implements Connector and which name matches io.debezium.connector.mysql.MySqlConnector"

Am I missing something? Anyone can help?

WATHANYU PHROMMA

unread,

Aug 14, 2018, 12:02:09 AM8/14/18

to debezium

Microsoft Windows [Version 10.0.16299.492]

C:\Users\wathanyu.phromma>cd C:\confluent-5.0.0

C:\confluent-5.0.0>bin\windows\connect-distributed.bat etc\kafka\connect-distributed.properties

[2018-08-14 10:58:32,839] WARN could not create Dir using jarFile from url file:/C:/confluent-5.0.0/share/java/kafka/kafka.jar. skipping. (org.reflections.Reflections)

java.util.zip.ZipException: zip file is empty

at java.base/java.util.zip.ZipFile$Source.zerror(Unknown Source)

at java.base/java.util.zip.ZipFile$Source.findEND(Unknown Source)

at java.base/java.util.zip.ZipFile$Source.initCEN(Unknown Source)

at java.base/java.util.zip.ZipFile$Source.<init>(Unknown Source)

at java.base/java.util.zip.ZipFile$Source.get(Unknown Source)

at java.base/java.util.zip.ZipFile$CleanableResource.<init>(Unknown Source)

at java.base/java.util.zip.ZipFile$CleanableResource.get(Unknown Source)

at java.base/java.util.zip.ZipFile.<init>(Unknown Source)

at java.base/java.util.jar.JarFile.<init>(Unknown Source)

at org.reflections.vfs.Vfs$DefaultUrlTypes$1.createDir(Vfs.java:216)

at org.reflections.vfs.Vfs.fromURL(Vfs.java:99)

at org.reflections.vfs.Vfs.fromURL(Vfs.java:91)

at org.reflections.Reflections.scan(Reflections.java:240)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.scan(DelegatingClassLoader.java:414)

at org.reflections.Reflections$1.run(Reflections.java:198)

at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)

at java.base/java.util.concurrent.FutureTask.run(Unknown Source)

at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)

at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)

at java.base/java.lang.Thread.run(Unknown Source)

[2018-08-14 10:58:33,250] WARN could not get type for name org.osgi.framework.BundleListener from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.osgi.framework.BundleListener

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.osgi.framework.BundleListener

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,274] WARN could not get type for name org.apache.kafka.common.utils.MockTime from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.apache.kafka.common.utils.MockTime

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.utils.MockTime

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,286] WARN could not get type for name com.google.gson.JsonDeserializer from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name com.google.gson.JsonDeserializer

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: com.google.gson.JsonDeserializer

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,293] WARN could not get type for name org.scalatest.junit.JUnitSuite from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.scalatest.junit.JUnitSuite

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.scalatest.junit.JUnitSuite

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,319] WARN could not get type for name org.jboss.marshalling.ByteInput from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.jboss.marshalling.ByteInput

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.jboss.marshalling.ByteInput

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,358] WARN could not get type for name org.easymock.IAnswer from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.easymock.IAnswer

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.easymock.IAnswer

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,404] WARN could not get type for name javax.mail.Authenticator from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name javax.mail.Authenticator

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: javax.mail.Authenticator

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,432] WARN could not get type for name org.apache.kafka.test.MockMetricsReporter from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.apache.kafka.test.MockMetricsReporter

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.test.MockMetricsReporter

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,435] WARN could not get type for name org.osgi.util.tracker.ServiceTracker from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.osgi.util.tracker.ServiceTracker

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.osgi.util.tracker.ServiceTracker

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,457] WARN could not get type for name org.eclipse.jetty.npn.NextProtoNego$ServerProvider from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.eclipse.jetty.npn.NextProtoNego$ServerProvider

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.eclipse.jetty.npn.NextProtoNego$ServerProvider

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,473] WARN could not get type for name javax.jms.MessageListener from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name javax.jms.MessageListener

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: javax.jms.MessageListener

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,495] WARN could not get type for name org.eclipse.jetty.jmx.ObjectMBean from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.eclipse.jetty.jmx.ObjectMBean

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.eclipse.jetty.jmx.ObjectMBean

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,511] WARN could not get type for name com.google.gson.JsonSerializer from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name com.google.gson.JsonSerializer

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: com.google.gson.JsonSerializer

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,550] WARN could not get type for name org.osgi.framework.BundleActivator from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.osgi.framework.BundleActivator

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.osgi.framework.BundleActivator

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,565] WARN could not get type for name org.apache.kafka.clients.admin.MockAdminClient from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.apache.kafka.clients.admin.MockAdminClient

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.clients.admin.MockAdminClient

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,587] WARN could not get type for name org.scalatest.Assertions from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.scalatest.Assertions

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.scalatest.Assertions

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,597] WARN could not get type for name org.jboss.marshalling.ByteOutput from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.jboss.marshalling.ByteOutput

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.jboss.marshalling.ByteOutput

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,622] WARN could not get type for name org.osgi.framework.SynchronousBundleListener from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.osgi.framework.SynchronousBundleListener

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.osgi.framework.SynchronousBundleListener

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,648] WARN could not get type for name org.eclipse.jetty.npn.NextProtoNego$ClientProvider from any class loader (org.reflections.Reflections)

org.reflections.ReflectionsException: could not get type for name org.eclipse.jetty.npn.NextProtoNego$ClientProvider

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390)

at org.reflections.Reflections.expandSuperTypes(Reflections.java:381)

at org.reflections.Reflections.<init>(Reflections.java:126)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(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.initPluginLoader(DelegatingClassLoader.java:188)

at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:181)

at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)

at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:74)

Caused by: java.lang.ClassNotFoundException: org.eclipse.jetty.npn.NextProtoNego$ClientProvider

at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)

at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown Source)

at java.base/java.lang.ClassLoader.loadClass(Unknown Source)

at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388)

... 9 more

[2018-08-14 10:58:33,887] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,887] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:33,903] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,280] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,280] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,290] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,291] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,291] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,292] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,292] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,293] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,293] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,293] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,294] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,294] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,294] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,361] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,361] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,364] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,365] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,373] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,373] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,374] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,374] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,375] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,381] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,394] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,397] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,397] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,458] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,458] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,461] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,469] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,470] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,471] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,471] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,472] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,473] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,473] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,474] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,474] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,584] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,585] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,588] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,594] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,595] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,596] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,596] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,597] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,598] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,598] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,599] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,599] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,600] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,642] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,643] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,646] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,658] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,659] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,660] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,660] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,661] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,662] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,662] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,663] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,663] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,664] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,692] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,692] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,693] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,693] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,694] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,695] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,696] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,697] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,707] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,708] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,709] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,710] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,848] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,848] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,853] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,857] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,858] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,858] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,859] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,859] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,860] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,860] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,861] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,861] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,862] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)

[2018-08-14 10:58:34,896] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,896] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,898] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,901] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,911] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,911] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,912] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,913] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,914] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,914] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,929] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,929] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,929] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'config.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'status.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'plugin.path' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'config.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,945] WARN The configuration 'status.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,961] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,961] WARN The configuration 'offset.storage.replication.factor' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,961] WARN The configuration 'offset.storage.topic' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,976] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:34,976] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig)

[2018-08-14 10:58:35,061] WARN Catching up to assignment's config offset. (org.apache.kafka.connect.runtime.distributed.DistributedHerder)

Aug 14, 2018 10:58:35 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime

WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.RootResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResource will be ignored.

Aug 14, 2018 10:58:35 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime

WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorsResource will be ignored.

Aug 14, 2018 10:58:35 AM org.glassfish.jersey.internal.inject.Providers checkProviderRuntime

WARNING: A provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource registered in SERVER runtime does not implement any provider interfaces applicable in the SERVER runtime. Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.ConnectorPluginsResource will be ignored.

Aug 14, 2018 10:58:35 AM org.glassfish.jersey.internal.Errors logErrors

WARNING: The following warnings have been detected: WARNING: 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.

WATHANYU PHROMMA

unread,

Aug 14, 2018, 12:04:51 AM8/14/18

to debezium

On Tuesday, August 14, 2018 at 12:02:43 AM UTC+7, WATHANYU PHROMMA wrote:

log file

Jiri Pechanec

unread,

Aug 14, 2018, 6:57:32 AM8/14/18

to debezium

ok, I made this steps

1) Download OSS Confluent 5 platform for windows

2) Extract Debezium mysql plugin into share\java directory

2.5) It might be necessary to remove some of Confluent's plugins as there were missing dependencies foir them

3) Start all components

All was running as expected

Jiri Pechanec

unread,

Aug 14, 2018, 11:30:59 PM8/14/18

to debezium

Can you try it this way? To confirm that such an installation is running? And then in the next step try to move it to a different directory?

WATHANYU PHROMMA

unread,

Aug 17, 2018, 3:45:42 AM8/17/18

to debezium

I solved this problem. Thank you very much for your help.

On Tuesday, August 14, 2018 at 12:02:43 AM UTC+7, WATHANYU PHROMMA wrote:

Gunnar Morling

unread,

Aug 20, 2018, 10:34:28 AM8/20/18

to debezium

Out of curiosity, what was the issue? Anything worth sharing in an FAQ entry for instance?