Error while deserializing history record

Skip to first unread message

Jehanzaib Younis

Apr 27, 2021, 1:00:51 AMApr 27
to debezium
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

Apr 27, 2021, 2:37:40 AMApr 27
to debezium
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.

Reply all
Reply to author
0 new messages