@Ross_Lawley @Robert_Walters I tried to use the 1.6.0 connector and the problem is the same - the sink connector works and the source connector does not with reason of DecodeException.
The logs are pretty much the same with another error:
Caused by: java.lang.ClassNotFoundException: org.apache.avro.Schema
at java.base/java.net.URLClassLoader.findClass(URLClassLoader.java:471)
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)
… 15 more
Added avro-1.3.2.jar to /opt/kafka/plugins (where the mongo plugin is) and nothing changed. (not sure if Avro is needed and if it is, does it matter the version of Avro)
In my docker file I take kafka 2.5.0 image, creating plugins directory (/opt/kafka/plugins)
and copying the mongo and avro plugins to that directory.