I’ve been making a user-event-aggregation system for Entity-Centric Indexing of Snowplow events in ElasticSearch:
Right now it’s reading JSON event kinesis stream generated from Snowplow’s Kinesis Tee project.
I’d like to change it to read directly from the raw Kinesis Enrich Stream. But enriched events pushed to Kinesis use a special, compressed format - right?
I know that there’s a Scala library to convert the compressed event data into JSON format. But I was wondering if there was any documentation I could read for doing it in Golang. Or any documentation I could read to program that conversion.