You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Zhou, Limin (Ray)" <ra...@moneris.com> on 2019/03/01 20:24:14 UTC

Error deserializing Avro message for id 25

Hello

I am seeing the following error in the log when consume the AVRO message, try to google it, no help, could anyone explain what the error means in here?

Thanks
Raymond

2019-02-27 01:37:35,135 ERROR [stderr] (default task-24) org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition MDDisputeAcceptRequest-0 at offset 23. If needed, please seek past the record to continue consumption.
2019-02-27 01:37:35,137 ERROR [stderr] (default task-24) Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 25
2019-02-27 01:37:35,139 ERROR [stderr] (default task-24) Caused by: org.apache.kafka.common.errors.SerializationException: Could not find class b24_ptlf_financial_formatted specified in writer's schema whilst finding reader's schema for a SpecificRecord.