Error while deserializing history record

[Jehanzaib Younis]

I have put Mytest manual test Message in my topic just for testig.

Now when i start the kafka connect i see below error: 

[2021-04-27 16:55:15,374] ERROR Error while deserializing history record 'ConsumerRecord(topic = mytest-topic, partition = 0, leaderEpoch = 4, offset = 7451, CreateTime = 1619497739347, serialized key size = -1, serialized value size = 27, headers = RecordHeaders(headers = [], isReadOnly = false), key = null, value = Mytest manual test Message)' (io.debezium.relational.history.KafkaDatabaseHistory:316)

com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'Mytest': was expecting (JSON String, Number, Array, Object or token 'null', 'true' or 'false')

Can anyone help me to resolve this?

Thank you

[Gunnar Morling]

The database history topic is an _internal_ topic of the connector; if you randomly write records to it which don't match the history record format, it's expected that the connector cannot read that back upon restart. Your best course is to set up a new connector instance with a new history topic name.

--Gunnar