Open dkumarkartik opened 2 years ago
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 31 Caused by: org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -7843832
Getting this issue while deserializing avro msg with Generic record. while msg contain some special character. for one type of schema. ex-
{ "op": "create", "id": "test-l广告oc-378621", "provenance": { "sourceDatasetId": "TEST" }, "properties": { "mg_display_label": "LOCA广告广告TION", "mg_entity_type": "location" }, "label": "location" }
but same process for another schema not throwing any exception. ex- { "op": "crea广告te", "id": "test-ind-lc广告-372386213", "provenance": { "sourceDatasetId": "TEST" }, "properties": { "mg_display_label": "hasLocation", "type": "home" }, "src": { "id": "test-ind-378621", "label": "individual" }, "dst": { "id": "test-loc-378621", "label": "location" }, "label": "hasLocation" }
what could be the reason, Can anybody help me on this. stocked here from last couple of days.
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 31 Caused by: org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -7843832
Getting this issue while deserializing avro msg with Generic record. while msg contain some special character. for one type of schema. ex-
{ "op": "create", "id": "test-l广告oc-378621", "provenance": { "sourceDatasetId": "TEST" }, "properties": { "mg_display_label": "LOCA广告广告TION", "mg_entity_type": "location" }, "label": "location" }
but same process for another schema not throwing any exception. ex- { "op": "crea广告te", "id": "test-ind-lc广告-372386213", "provenance": { "sourceDatasetId": "TEST" }, "properties": { "mg_display_label": "hasLocation", "type": "home" }, "src": { "id": "test-ind-378621", "label": "individual" }, "dst": { "id": "test-loc-378621", "label": "location" }, "label": "hasLocation" }
what could be the reason, Can anybody help me on this. stocked here from last couple of days.