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.

Reply via email to