Skip to content

Instantly share code, notes, and snippets.

View arun2dot0's full-sized avatar

Arun Selvamani arun2dot0

3 followers · 20 following
View GitHub Profile
@arun2dot0
arun2dot0 / RunnableGraphStreamWrapperActor.java
Created December 24, 2021 02:01 — forked from Jayasagar/RunnableGraphStreamWrapperActor.java
Complete example reference to Partition Graph and Reactive Kafka
package sample.javadsl;
import akka.Done;
import akka.NotUsed;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.PoisonPill;
import akka.actor.Props;
import akka.actor.UntypedActor;
import akka.japi.function.Function;