Added support for avro message format
Added kafka offset to avro message and used it to trim files