Want to expose an API? Reactive Options

Vikas HazratiFebruary 6, 2019February 6, 2019Akka, akka-streams, Architecture, Big Data and Fast Data, Business Insights, Reactive Programming, Scala

In the modern digital world, a system which cannot talk to other systems or does not allow other systems to talk to itself is bound to fail. A lot of organizations that we work with be it large banks, healthcare institutions, travel booking and predictions, industrial analysers, would like to expose their ecosystem through an API so that it is available as a platform for other companies and products to consume and innovate on.

Alpakka – Connecting Kafka and ElasticSearch to Akka streams

Anmol SarnaNovember 12, 2018November 12, 2018Akka, akka-streams, Apache Kafka, Elasticsearch, Scala, Streamingakka-streams, alpakka, connector, elasticsearch, kafka, Streams

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 SarnaOctober 16, 2018October 16, 2018Akka, akka-streams, Java, Scala, Streaming, Streaming SolutionsAkka actor, akka-streaming, broadcasting, Data Flow Graphs, scala, Streams

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 GoelOctober 15, 2018October 16, 2018Akka, akka-streams, ScalaAkka actor, akka-streams, back2basics, Getting Started

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 GandhiOctober 1, 2018October 1, 2018Akka, akka-http, akka-streams, Scalaakka-http, 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

DeepankarJune 21, 2018August 8, 2018Akka, 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 KhattriMay 4, 2018July 23, 2018Akka, akka-streams, Play Framework, ScalaAkka, akka-streams, alpakka, amazon web services, AWS, aws s3, File Transfer, File upload, Play framework, Reactive Programming, reactive streams, Streaming

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

akka-streams