reactive streams Archives

Batch Operations in Reactive Stream – Using buffer with Project Reactor

March 1, 2023March 1, 2023Java, reactive programing, Reactive Programmingreactive streams

Reading Time: 2 minutes Reactive streams support infinite data and handle backpressure. What if we want to perform a batch operation on top of the reactive stream. Can we batch over the infinite stream? In this blog, we will see how we can batch with Project Reactor reactive stream without breaking the streaming boundary and with handling the backpressure. The Problem Space In my project, one of the Microservice’s Continue Reading

Akka Streams | Three Basic Components

October 29, 2021October 29, 2021Akka, akka-streams, Reactive Architecture, Studio-ScalaAkka, akka-streams, reactive streams

Reading Time: 3 minutes Akka, a free open source toolkit simplifying the construction of concurrent and distributed system/application. We have already deal with Akka Actors where we learnt about the Akka Actors and their Behaviors. But Actors can be seen dealing with with Sequence of Data where they send or receive series of messages. So, In this blog we discuss Akka Stream in bit detail. What is Akka Streams Continue Reading

Reactive Streams with JAVA 9

March 26, 2020Java, Reactive Application, Reactive Programmingdata flow, java9, learning, programming, reactive streams, technology

Reading Time: 5 minutes With the introduction of Java 9, Java community has started to show its support directly towards Reactive streams, which was earlier used by leveraging third-party libraries. Please visit my earlier blog on Reactive streams to understand the basic ideologies which are working behind it like the push-pull model or backpressure. As a part of this blog, we will explore how we can leverage the same Continue Reading

Knolx: Alpakka-Connecting Kafka & ElasticSearch to Akka Streams

May 1, 2019June 19, 2019Akka, akka-streams, Apache Kafka, Elasticsearch, Streaming, Studio-Scalaakka-streams, alpakka, connector, elasticsearch, kafka, reactive streams, Streams

Reading Time: < 1 minute Hi all, Knoldus has organized a 30 min session on 1st March 2019 at 3:30 PM. The topic was Alpakka – Connecting Kafka and ElasticSearch to Akka Streams. Many people have joined and enjoyed the session. I am going to share the slides here. Please let me know if you have any question related to linked slides or video. The slides of the KnolX are here: And Continue Reading

Reactivate your streams with Reactive Streams!!

March 5, 2019March 5, 2019akka-streams, Reactive Application, Streaming, Streaming Solutions, Studio-ScalaAsynchronous, backpressure, Reactive Manifesto, reactive streams, Streams

Reading Time: 5 minutes As you all might have known by now that one of the hot topics for quite some time has been streaming of big data. Day after day, we see tons of streaming technologies out there competing with one another. The obvious reason for that, processing big volumes of data is not enough. We need real-time processing of data, especially when we need to handle continuously increasing Continue Reading

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

May 4, 2018July 23, 2018Akka, akka-streams, Play Framework, Studio-ScalaAkka, akka-streams, alpakka, amazon web services, AWS, aws s3, File Transfer, File upload, Play framework, Reactive Programming, reactive streams, Streaming

Reading Time: 5 minutes 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