in CustomDeserializers/AvroExample/EventhubCaptureReader.cs [65:86]
private EventDataFromCapture ConvertToEventDataFromCapture(GenericRecord genericRecord)
{
try
{
var eventData = new EventDataFromCapture()
{
EnqueuedTimeUtc = (string)genericRecord["EnqueuedTimeUtc"],
Offset = (string)genericRecord["Offset"],
SequenceNumber = (long)genericRecord["SequenceNumber"],
Body = (byte[])genericRecord["Body"],
};
return eventData;
}
catch(Exception e)
{
this.diagnostics.WriteError(
briefMessage: $"Unable to get fields required to create captured event data. Error: {e.Message}",
detailedMessage: e.ToString());
throw;
}
}