Skip to content

Instantly share code, notes, and snippets.

import _root_.kafka.serializer.{StringDecoder, StringEncoder}
import akka.actor.SupervisorStrategy.{Restart, Resume}
import akka.actor.{Props, OneForOneStrategy, SupervisorStrategy, ActorSystem}
import akka.stream.actor.ActorSubscriber
import akka.stream.{ActorMaterializerSettings, Supervision, ActorMaterializer}
import akka.stream.scaladsl.{Sink, Source}
import com.softwaremill.react.kafka.KafkaMessages.StringKafkaMessage
import com.softwaremill.react.kafka.{ConsumerProperties, ProducerProperties, ReactiveKafka}
import org.reactivestreams.{Publisher, Subscriber}
@andreionut
andreionut / keybase.md
Created January 6, 2016 17:18
keybase.md

Keybase proof

I hereby claim:

  • I am andreionut on github.
  • I am andreionut (https://keybase.io/andreionut) on keybase.
  • I have a public key ASBgDrRDS8F2_oqG_AOUaPX32poufhyHYVBb3MFElmdX7Qo

To claim this, I am signing this object:

@andreionut
andreionut / .gitconfig
Created August 12, 2015 13:32
Git config
[core]
excludesfile = ~/.gitignore
precomposeunicode = false
quotepath = false
[branch]
autosetuprebase = always
[push]
default = upstream
Elixir 1.0.2 Code:
iex(1)> :inets.start
:ok
iex(2)> :ssl.start
:ok
iex(3)> :ssl.connect("gateway.sandbox.push.apple.com", 2195, [{:mode, :binary}, {:certfile, "/path_to_cert.pem"}], 30000)
{:error, {:options, {:socket_options, [mode: :binary]}}}
iex(5)> :ssl.connect("api.github.com", 443, [], 30000)
#!/usr/bin/env ruby
# encoding: utf-8
# poor man's flycheck for Erlang
# It looks at the modified files via `git status`, compiles them,
# and displays the errors, if any.
# For simplicity it outputs the beam's in /tmp
@repo_root = `git rev-parse --show-toplevel`.strip