Skip to content

Instantly share code, notes, and snippets.

🎯
Focusing

Julian Wilson mrwillis

View GitHub Profile
@mrwillis
mrwillis / main.scala
Created Jun 2, 2018
Kafka BroadcastHub (reactive-kafka)
View main.scala
import akka.NotUsed
import akka.actor.ActorSystem
import akka.kafka.scaladsl.Consumer
import akka.kafka.{ConsumerSettings, KafkaConsumerActor, Subscriptions}
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{BroadcastHub, Keep, RunnableGraph, Sink, Source}
import org.apache.kafka.clients.consumer.ConsumerRecord
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.serialization.StringDeserializer
You can’t perform that action at this time.