lensesio/kafka-connect-common

JsonSimpleConverter unable to fetch MsgKey

Closed this issue · 0 comments

Found this issue using JsonSimpleConverter

java.lang.NoClassDefFoundError: com.datamountaineer.streamreactor.connect.converters.MsgKey$ (initialization failure)\n\tat java.base/java.lang.J9VMInternals.initializationAlreadyFailed(J9VMInternals.java:143)\n\tat com.datamountaineer.streamreactor.connect.converters.source.JsonSimpleConverter.convert(JsonSimpleConverter.scala:56)\n\tat com.datamountaineer.streamreactor.connect.jms.source.readers.JMSReader.convert(JMSReader.scala:55)\n\tat com.datamountaineer.streamreactor.connect.jms.source.readers.JMSReader$$anonfun$3$$anonfun$apply$2.apply(JMSReader.scala:47)\n\tat com.datamountaineer.streamreactor.connect.jms.source.readers.JMSReader$$anonfun$3$$anonfun$apply$2.apply(JMSReader.scala:47)\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)\n\tat scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)\n\t

i guess the import statement should be
import com.datamountaineer.streamreactor.connect.converters.source.MsgKey
rather than
import com.datamountaineer.streamreactor.connect.converters.MsgKey