Error while deserializing history record

7 views
Skip to first unread message

Jehanzaib Younis

unread,
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

unread,
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.

--Gunnar
Reply all
Reply to author
Forward
0 new messages