alpakka-samples
alpakka-samples copied to clipboard
akka
Example projects building Reactive Integrations using Alpakka
The nasdaq changed the way they share data with the outside world. Just to see it working I've used another open source csv val uriCsv = "https://www.stats.govt.nz/assets/Uploads/Annual-enterprise-survey/Annual-enterprise-survey-2019-financial-year-provisional/Download-data/annual-enterprise-survey-2019-financial-year-provisional-csv.csv" It's probably not...
Something of that kind seems to come up quite often. One of the questions here is whether you would create a consumer for the queue (e.g. kafka, or some pubsub)...
### Short description The examples currently use the `studentify` training aid to instruct users how to interatively develop any given example. This is good for training purposes, but it can...
### Short description FTP self-contained example (https://doc.akka.io/docs/alpakka/current/examples/ftp-samples.html) should be moved to this repository as a step-by-step example (as Kafka example was: https://github.com/akka/alpakka-samples/pull/13).
### Short description For example, the GLEI files from https://www.gleif.org/en/lei-data/gleif-concatenated-file/download-the-concatenated-file# are a great use case for streaming XML parsing. ### Details The files are in ZIP format which we don't...
### Short description Alpakka SQS changed the API in 1.0.1, the example should show that API.
Adapt the MQTT to S3 example to using the MQTT streaming implementation instead. I'd like to discuss a more "standard use-case" API with @huntc.
When am trying to run your code, I get this run time exception being thrown. I have my AWS SQS queue configured and the URLs replaced in the source code....
``` Exception (java.lang.AssertionError) encountered during startup: java.lang.reflect.InaccessibleObjectException: Unable to make field private int java.io.FileDescriptor.fd accessible: module java.base does not "opens java.io" to unnamed module @41a962cf ``` We need to add...
