You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm trying to set up Glue schema registry with AVRO deserialization and I encountered the following issue in the UI: "Fallback serde was used."
Looking at the logs, I don't see any errors.
However, based on the code, I should at least see:
Error deserializing key for value topic: {}
Here is the relevant code snippet from the repo:
private void fillValue(TopicMessageDTO message, ConsumerRecord<Bytes, Bytes> rec) {
if (rec.value() == null) {
return;
}
try {
var deserResult = valueDeserializer.deserialize(
new RecordHeadersImpl(rec.headers()), rec.value().get());
message.setContent(deserResult.getResult());
message.setValueSerde(valueSerdeName);
message.setValueDeserializeProperties(deserResult.getAdditionalProperties());
} catch (Exception e) {
log.trace("Error deserializing key for value topic: {}, partition {}, offset {}, with serde {}",
rec.topic(), rec.partition(), rec.offset(), valueSerdeName, e);
var deserResult = fallbackValueDeserializer.deserialize(
new RecordHeadersImpl(rec.headers()), rec.value().get());
message.setContent(deserResult.getResult());
message.setValueSerde(fallbackSerdeName);
}
}
I checked CloudTrail and found a successful API call to the correct schema registry and schema name. However, I only see a GetSchema call that contains schema metadata but not the actual schema definition. I was also expecting to see a GetSchemaVersion API call.
Any suggestions on how I should troubleshoot this issue?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
I'm trying to set up Glue schema registry with AVRO deserialization and I encountered the following issue in the UI: "Fallback serde was used."
Looking at the logs, I don't see any errors.
However, based on the code, I should at least see:
Error deserializing key for value topic: {}
Here is the relevant code snippet from the repo:
I checked CloudTrail and found a successful API call to the correct schema registry and schema name. However, I only see a GetSchema call that contains schema metadata but not the actual schema definition. I was also expecting to see a GetSchemaVersion API call.
Any suggestions on how I should troubleshoot this issue?
Beta Was this translation helpful? Give feedback.
All reactions