[2020-12-16 10:27:26,834] ERROR Connect exception {} (com.ibm.eventstreams.connect.mqsource.JMSReader:294) org.apache.kafka.connect.errors.DataException: Converting byte[] to Kafka Connect data failed due to serialization error: at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:344) at com.ibm.eventstreams.connect.mqsource.builders.JsonRecordBuilder.getValue(JsonRecordBuilder.java:82) at com.ibm.eventstreams.connect.mqsource.builders.BaseRecordBuilder.toSourceRecord(BaseRecordBuilder.java:168) at com.ibm.eventstreams.connect.mqsource.JMSReader.receive(JMSReader.java:285) at com.ibm.eventstreams.connect.mqsource.MQSourceTask.poll(MQSourceTask.java:124) at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.common.errors.SerializationException: com.fasterxml.jackson.core.JsonParseException: Unrecognized character escape 'P' (code 80) at [Source: (byte[])""DB;1200;000;000;4134522063660201 ;000000;458;00000000173.60;458;00000000173.60;12122020;181044;458;5999;00 ; ;570108;034710444248;000000000016808;261;Y;Y;V;V; ;8888 ;64514071 ;tempName ;MYS;009882463; ; ;IEF66000;Y;I;VISA DEBIT ;MYCLEAR / MCCS ;20201212181043; ;8000048000;54337BD4840DBCBE;A0000006150001 ;Y;034710444248;01;B24 ;4283322063660201;101049171"[truncated 503 bytes]; line: 1, column: 520] Caused by: com.fasterxml.jackson.core.JsonParseException: Unrecognized character escape 'P' (code 80) at [Source: (byte[])""DB;1200;000;000;4134522063660201 ;000000;458;00000000173.60;458;00000000173.60;12122020;181044;458;5999;00 ; ;570108;034710444248;000000000016808;261;Y;Y;V;V; ;8888 ;64514071 ;tempName ;MYS;009882463; ; ;IEF66000;Y;I;VISA DEBIT ;MYCLEAR / MCCS ;20201212181043; ;8000048000;54337BD4840DBCBE;A0000006150001 ;Y;034710444248;01;B24 ;4134522063660201;101049171"[truncated 503 bytes]; line: 1, column: 520] at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1804) at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:693) at com.fasterxml.jackson.core.base.ParserMinimalBase._handleUnrecognizedCharacterEscape(ParserMinimalBase.java:670) at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._decodeEscaped(UTF8StreamJsonParser.java:3249) at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._finishString2(UTF8StreamJsonParser.java:2458) at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._finishAndReturnString(UTF8StreamJsonParser.java:2413) at com.fasterxml.jackson.core.json.UTF8StreamJsonParser.getText(UTF8StreamJsonParser.java:269) at com.fasterxml.jackson.databind.deser.std.BaseNodeDeserializer.deserializeAny(JsonNodeDeserializer.java:523) at com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:73) at com.fasterxml.jackson.databind.deser.std.JsonNodeDeserializer.deserialize(JsonNodeDeserializer.java:15) at com.fasterxml.jackson.databind.ObjectMapper._readTreeAndClose(ObjectMapper.java:4057) at com.fasterxml.jackson.databind.ObjectMapper.readTree(ObjectMapper.java:2572) at org.apache.kafka.connect.json.JsonDeserializer.deserialize(JsonDeserializer.java:45) at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:342) at com.ibm.eventstreams.connect.mqsource.builders.JsonRecordBuilder.getValue(JsonRecordBuilder.java:82) at com.ibm.eventstreams.connect.mqsource.builders.BaseRecordBuilder.toSourceRecord(BaseRecordBuilder.java:168) at com.ibm.eventstreams.connect.mqsource.JMSReader.receive(JMSReader.java:285) at com.ibm.eventstreams.connect.mqsource.MQSourceTask.poll(MQSourceTask.java:124)