Arun Selvamani arun2dot0

😀

Container Security !

Right now doing Container Security . https://2minsecurity.blogspot.com/ https://2minai.blogspot.com/ https://ajaxrocks.blogspot.com

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;