I’m currently implementing Scala Collector and Pushing Raw Messages to SQS, decoding messages is proving tricky. I’m guessing there is a better way to do this than I’m aware.
We’ve just moved the docs to a new home and some of the old redirects have broken. Could you point me to where you found that link? As in, the url where you found the link and clicked it?
You need to run the Enrich process to read the collector events, however, a typical pipeline doesn’t write to SQS from the collector, and as such the enrich library is designed to read from Kinesis. So I’d suggest writing to Kinesis from the collector and then setting up enrich-kinesis
I’ve just pushed some updates to the docs too, to help with this. They should be live shortly.