Debezium MySQL Connector (Unsupported major.minor version 52.0)

[Mano Haran]

I have been trying bring up the Debezium  MySQL connector on my local machine.. 

I'm using 
MySQL - 5.6.37
Debezium - 0.6.0 

[2017-10-31 10:42:28,800] WARN could not get type for name io.debezium.connector.mysql.MySqlConnector from any class loader (org.reflections.Reflections:384)

org.reflections.ReflectionsException: could not get type for name io.debezium.connector.mysql.MySqlConnector

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

at org.reflections.ReflectionUtils.forNames(ReflectionUtils.java:397)

at org.reflections.Reflections.getSubTypesOf(Reflections.java:367)

at org.apache.kafka.connect.runtime.PluginDiscovery.connectorPlugins(PluginDiscovery.java:76)

at org.apache.kafka.connect.runtime.PluginDiscovery.scanClasspathForPlugins(PluginDiscovery.java:70)

at org.apache.kafka.connect.runtime.AbstractHerder$1.run(AbstractHerder.java:390)

at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.UnsupportedClassVersionError: io/debezium/connector/mysql/MySqlConnector : Unsupported major.minor version 52.0

at java.lang.ClassLoader.defineClass1(Native Method)

at java.lang.ClassLoader.defineClass(ClassLoader.java:800)

at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)

at java.net.URLClassLoader.access$100(URLClassLoader.java:71)

at java.net.URLClassLoader$1.run(URLClassLoader.java:361)

at java.net.URLClassLoader$1.run(URLClassLoader.java:355)

at java.security.AccessController.doPrivileged(Native Method)

at java.net.URLClassLoader.findClass(URLClassLoader.java:354)

at java.lang.ClassLoader.loadClass(ClassLoader.java:425)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

at java.lang.ClassLoader.loadClass(ClassLoader.java:358)

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

... 6 more

[2017-10-31 10:42:28,811] WARN could not get type for name io.debezium.transforms.UnwrapFromEnvelope from any class loader (org.reflections.Reflections:384)

org.reflections.ReflectionsException: could not get type for name io.debezium.transforms.UnwrapFromEnvelope

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

at org.reflections.ReflectionUtils.forNames(ReflectionUtils.java:397)

at org.reflections.Reflections.getSubTypesOf(Reflections.java:367)

at org.apache.kafka.connect.runtime.PluginDiscovery.transformationPlugins(PluginDiscovery.java:97)

at org.apache.kafka.connect.runtime.PluginDiscovery.scanClasspathForPlugins(PluginDiscovery.java:71)

at org.apache.kafka.connect.runtime.AbstractHerder$1.run(AbstractHerder.java:390)

at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.UnsupportedClassVersionError: io/debezium/transforms/UnwrapFromEnvelope : Unsupported major.minor version 52.0

at java.lang.ClassLoader.defineClass1(Native Method)

at java.lang.ClassLoader.defineClass(ClassLoader.java:800)

at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)

at java.net.URLClassLoader.access$100(URLClassLoader.java:71)

at java.net.URLClassLoader$1.run(URLClassLoader.java:361)

at java.net.URLClassLoader$1.run(URLClassLoader.java:355)

at java.security.AccessController.doPrivileged(Native Method)

at java.net.URLClassLoader.findClass(URLClassLoader.java:354)

at java.lang.ClassLoader.loadClass(ClassLoader.java:425)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

at java.lang.ClassLoader.loadClass(ClassLoader.java:358)

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

... 6 more

[2017-10-31 10:42:28,815] WARN could not get type for name io.debezium.transforms.ByLogicalTableRouter from any class loader (org.reflections.Reflections:384)

org.reflections.ReflectionsException: could not get type for name io.debezium.transforms.ByLogicalTableRouter

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

at org.reflections.ReflectionUtils.forNames(ReflectionUtils.java:397)

at org.reflections.Reflections.getSubTypesOf(Reflections.java:367)

at org.apache.kafka.connect.runtime.PluginDiscovery.transformationPlugins(PluginDiscovery.java:97)

at org.apache.kafka.connect.runtime.PluginDiscovery.scanClasspathForPlugins(PluginDiscovery.java:71)

at org.apache.kafka.connect.runtime.AbstractHerder$1.run(AbstractHerder.java:390)

at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.UnsupportedClassVersionError: io/debezium/transforms/ByLogicalTableRouter : Unsupported major.minor version 52.0

at java.lang.ClassLoader.defineClass1(Native Method)

at java.lang.ClassLoader.defineClass(ClassLoader.java:800)

at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)

at java.net.URLClassLoader.defineClass(URLClassLoader.java:449)

at java.net.URLClassLoader.access$100(URLClassLoader.java:71)

at java.net.URLClassLoader$1.run(URLClassLoader.java:361)

at java.net.URLClassLoader$1.run(URLClassLoader.java:355)

at java.security.AccessController.doPrivileged(Native Method)

at java.net.URLClassLoader.findClass(URLClassLoader.java:354)

at java.lang.ClassLoader.loadClass(ClassLoader.java:425)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)

at java.lang.ClassLoader.loadClass(ClassLoader.java:358)

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

... 6 more

[Jiri Pechanec]

Hi,

could you please verify that you are using Java 8?

J.

[Mano Haran]

Hi,

 I'm using Java 7. Should I be using 8 ?

thanks.
Mano

[Gunnar Morling]

Hi,

Yes, you'll need Java 8 to run Debezium.

--Gunnar

[Mano Haran]

Thanks a lot, It works after Java update.

However when I try to register a connector via REST API, 

I get the following,

{

    "error_code": 400,

    "message": "Connector configuration is invalid and contains the following 3 error(s):\nA value is required\nA value is required\nUnable to connect: Access denied for user 'root'@'10.0.2.58' (using password: YES)\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"

} 

my config : 

{

 "name": "connect-mysql",  

 "config": 

 {    

   "connector.class": "io.debezium.connector.mysql.MySqlConnector",    

   "database.hostname": "10.0.3.212",    

   "database.port": "3306",    

   "database.user": "root",   

   "database.password": "********",    

   "database.server.name": "*R*R*",    

   "database.whitelist": "*E*E",

   "table.whitelist": "member,member_preference,member_stat",

   "include.schema.changes"  : "false"  

 }

}

Note that my host name is different from what the log shows.. 

[Jiri Pechanec]

Is it possible that the server you are connecting to has multiple IP addresses?

Could you try to manuall connect to any of those two IPs?

J.