We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
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.
The text was updated successfully, but these errors were encountered:
No branches or pull requests
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.
The text was updated successfully, but these errors were encountered: