This example uses Alpakka FTP to download files from an FTP server.
This example uses Akka HTTP to send the HTTP request and Akka HTTP’s JSON support to convert the map into a JSON structure which gets published to a Kafka topic.
This example uses receives JMS messages with Alpakka JMS and sends those to different technologies.
This example uses Alpakka Slick to read from a relational database and write the data to Elasticsearch.
This example uses Alpakka Kafka to read from an Apache Kafka topic, parse the messages as JSON and write the data to Elasticsearch, committing offsets to Kafka after successfully updating Elasticsearch.
This example uses Alpakka File to watch for new files created in a directory and then tails them (similar to Elasticsearch’s
logstash utility). The tailed logs are parsed and indexed in Elasticsearch using Alpakka Elasticsearch.
Read a stream of data and store it zipped in rotating files on an SFTP server.
Listen to an Amazon SQS topic, enrich the message via calling an actor, publish a new message to SQS and acknowledge/delete the original message. (Java only)
Listen to a MQTT topic, download from the URL passed in the received message, and upload the data from that address to AWS S3. (Java only)