Read Avro EventHubs capture file (credit @Kadajski)

avroreader.cs

using Microsoft.Hadoop.Avro.Container;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.IO;
using System.Text;

namespace AvroReader
{
    public class AvroEventData
    {
        public AvroEventData(dynamic record)
        {
            SequenceNumber = (long)record.SequenceNumber;
            Offset = (string)record.Offset;
            DateTime.TryParse((string)record.EnqueuedTimeUtc, out var enqueuedTimeUtc);
            EnqueuedTimeUtc = enqueuedTimeUtc;
            SystemProperties = (Dictionary<string, object>)record.SystemProperties;
            Properties = (Dictionary<string, object>)record.Properties;
            Body = (byte[])record.Body;
        }
        public long SequenceNumber { get; set; }
        public string Offset { get; set; }
        public DateTime EnqueuedTimeUtc { get; set; }
        public Dictionary<string, object> SystemProperties { get; set; }
        public Dictionary<string, object> Properties { get; set; }
        public byte[] Body { get; set; }
    }

    public static class AvroReader
    {
        public static void ReadRecursive<T>(string path, List<T> items) where T : new()
        {
            var files = Directory.GetFiles(path);
            foreach (var file in files)
            {
                using (var stream = File.OpenRead(file))
                using (var reader = AvroContainer.CreateGenericReader(stream))
                {
                    try
                    {
                        while (reader.MoveNext())
                        {
                            foreach (dynamic result in reader.Current.Objects)
                            {
                                var record = new AvroEventData(result);
                                if (record.Body.Length == 0)
                                {
                                    continue;
                                }
                                var obj = JsonConvert.DeserializeObject<T>(Encoding.UTF8.GetString(record.Body));
                                if (EqualityComparer<T>.Default.Equals(obj, default(T)) == false)
                                {
                                    items.Add(obj);
                                }
                            }
                        }
                    }
                    catch (System.ArgumentOutOfRangeException)
                    {

                    }
                }
            }