Skip to content

Instantly share code, notes, and snippets.

View mrwillis's full-sized avatar
🎯
Focusing

Julian Wilson mrwillis

🎯
Focusing
View GitHub Profile
{
"contractName": "Fills",
"abi": [
{
"inputs": [
{
"internalType": "contract IFillOrder",
"name": "_fillOrder",
"type": "address"
},
@mrwillis
mrwillis / main.scala
Created June 2, 2018 21:15
Kafka BroadcastHub (reactive-kafka)
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