akka-streams

Alpakka – Connecting Kafka and ElasticSearch to Akka streams

Anmol SarnaAkka, akka-streams, Apache Kafka, Elasticsearch, Scala, Streaming, , , , ,

In our previous blog, we had a look at what Akka streams are and how they are different from the other streaming mechanisms we have. In this blog, we will be taking a little step forward into the world of Akka Streams. In order to work with Akka streams, we need a mechanism to connect Akka Streams to the existing system components. That is where Alpakka Continue Reading

Akka Streams: Is it a Solution to Your Streaming Problems?

Anmol SarnaAkka, akka-streams, Java, Scala, Streaming, Streaming Solutions, , , , ,

A few days earlier, in our project, we were using Spark streaming and initially, it worked like a charm. But as we were very close to completion of our use case, the unexpected occurred. Spark does have a lot of interesting features, but we had some more custom needs such as running a ton of varying jobs with different actors/flows. Also, we needed something which Continue Reading

Introduction to Akka Streams – Part 1

Aashrita GoelAkka, akka-streams, Scala, , ,

Akka Streams is a library that is used to process and transform a stream of data. In this blog, I’ll be discussing the components of Akka Streams. Akka Streams is an implementation of Reactive Streams and uses bounded buffer space, and this property is known as boundedness. To use Akka Streams, add the below dependency in your build.sbt:

Trying to use form field and file upload directive together in Akka-Http?

Miral GandhiAkka, akka-http, akka-streams, Scala,

If you are reading this then probably you have encountered the issue that comes while accessing fields with uploading a file, and if not then let me first tell you what’s the situation that I’m talking about here, Let’s see the code where we try to use fileUpload directive and formFields together

Akka http with json4s

DeepankarAkka, akka-http, akka-streams, Future, github, Scala, scalatest, Tutorial

Akka Http uses the spray-json library for JSON support. But a few days back while working on a project which was using the json4s library for marshalling/unmarshalling, I got stuck during parsing of JSON request and extracting that parsed values into my target Scala data model.

Stream a file to AWS S3 using Akka Streams (via Alpakka) in Play Framework

Sidharth KhattriAkka, akka-streams, Play Framework, Scala, , , , , , , , , , ,

In this blog post we’ll see how a file can be streamed from a client (eg: browser) to Amazon S3 (AWS S3) using Alpakka’s AWS S3 connector. Aplakka provides various Akka Stream connectors, integration patterns and data transformations for integration use cases. The example in this blog post uses Play Framework to provide a user interface to submit a file from a web page directly to Continue Reading

%d bloggers like this: