Kafka Connect - Sink Connector ( Production ) - Fails at JsonConverter.

[Saravanan Tirugnanum]

We are using Kafka 10 running in production with SinkConnector pulling from topic where it has messages generated from same source.

While its working for most of the messages but some of them are failing with Json Parser Error. 

Main reason is that we see some characters getting appended before the actual messages. Wondering where this is happening.

P:S = XXXX is masked as we get topicname instead.

Any pointers would help?

Error inside toConnectData. Message: 
topic&XXXXXXX timestam?1477076366925�X
topic&XXXXXXXtimestam?1477075658304�W
topic&XXXXXXX timestam?1477075358297�V{"header":{"version":"1.0.0","producerId"

org.apache.kafka.common.errors.SerializationException: com.fasterxml.jackson.core.JsonParseException: Illegal character ((CTRL-CHAR, code 4)): only regular white space (\r, \n, \t) is allowed between tokens
 at [Source: [B@1edcb93b; line: 1, column: 2]
Caused by: com.fasterxml.jackson.core.JsonParseException: Illegal character ((CTRL-CHAR, code 4)): only regular white space (\r, \n, \t) is allowed between tokens
 at [Source: [B@1edcb93b; line: 1, column: 2]
        at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1581)