I currently have Snowplow implemented as follows
Scala Collector -> Kinesis -> Scala Enrich -> Kinesis -> S3 Loader (as LZO) AND Elasticsearch loader
We’ve encountered some issues with the Elasticsearch loader/cluster, and were hoping to re-ingest the data out of S3 and into Elasticsearch. What is the best way to go about this/is this possible?
Thanks in advance!