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.
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)