A repository with Snowplow recovery mechanism for Real-time data pipeline S3 backup file.

Recovery mechanism can either emit base64 encoded records to stdout or write directly to the Kinesis stream.

Backup raw files may be picked up either form S3 bucket (with file name prefix or not) or form a local file (currently only a single one supported).

Line 48 is the answer.

Thrift schema is taken from official Snowplow repo: collector-payload.thrift